[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716285#comment-13716285
]
Joel Koshy commented on KAFKA-982:
--
+1 for 298, and I like Jakob's recursive suggestion as
Hi, we use Kafka (0.7.2 version) in our product as message delivery service
and message storage (our retention time 48h) system. Thanks a lot for
perfect tool/lib. Now we really need 2 additional features:
1. Sometimes we need look at our messages we have in Kafka from command
line, for example:
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-982:
Attachment: 301.png
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716544#comment-13716544
]
Neha Narkhede commented on KAFKA-982:
-
+1 for 298, it's clean and simple. Second choice
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716562#comment-13716562
]
Neha Narkhede commented on KAFKA-982:
-
Oops, my bad. I meant 294 as my 2nd choice.
[
https://issues.apache.org/jira/browse/KAFKA-879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-879:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716567#comment-13716567
]
Chris Riccomini commented on KAFKA-982:
---
+1 301
Logo for Kafka
[
https://issues.apache.org/jira/browse/KAFKA-922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-922:
--
Resolution: Fixed
Fix Version/s: 0.8
Assignee: John Fung
Status: Resolved (was:
[
https://issues.apache.org/jira/browse/KAFKA-922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-922.
-
System Test - set retry.backoff.ms=300 to testcase_0119
---
[
https://issues.apache.org/jira/browse/KAFKA-932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-932:
--
Resolution: Fixed
Fix Version/s: 0.8
Assignee: John Fung
Status: Resolved (was:
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716583#comment-13716583
]
Neha Narkhede commented on KAFKA-987:
-
Thanks for the patch, Swapnil. Good thinking
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716593#comment-13716593
]
Joel Koshy commented on KAFKA-925:
--
+1 , looks good to me.
DefaultPartitioner: Do we need
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716601#comment-13716601
]
Jay Kreps commented on KAFKA-982:
-
Not sure that I get 301, what are the pictures? They
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716607#comment-13716607
]
David Arthur commented on KAFKA-982:
[~jkreps], to me they look like messages in a log
[
https://issues.apache.org/jira/browse/KAFKA-882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-882:
--
Resolution: Fixed
Fix Version/s: 0.7
Status: Resolved (was: Patch Available)
Thanks for the
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-984:
Status: Patch Available (was: Open)
Avoid a full rebalance in cases when a new topic is
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-984:
Attachment: KAFKA-984.v1.patch
Avoid a full rebalance in cases when a new topic is discovered
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-987:
Attachment: kafka-987-v2.patch
Yes, thank you. Attached v2.
Avoid checkpointing
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716680#comment-13716680
]
Neha Narkhede commented on KAFKA-987:
-
+1 on v2.
Avoid checkpointing
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede resolved KAFKA-987.
-
Resolution: Fixed
Avoid checkpointing offsets in Kafka consumer that have not changed since
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716683#comment-13716683
]
Neha Narkhede commented on KAFKA-987:
-
committed v2 to 0.8
Avoid
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716697#comment-13716697
]
Mahendra M commented on KAFKA-982:
--
+296, 298
Logo for Kafka
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13717618#comment-13717618
]
Benjamin Black commented on KAFKA-982:
--
None of them make much sense, but 296 is least
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-984:
Attachment: KAFKA-984.v2.patch
Added one more unit test in ZookeeperConsumerConnectorTest for
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13717807#comment-13717807
]
Jay Kreps commented on KAFKA-982:
-
Okay, someone just pointed out that 294 is...uh...kind
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13717894#comment-13717894
]
Swapnil Ghike commented on KAFKA-984:
-
Hey Guozhang, this looks like a reasonable
For 1, you can write a tool that uses our getOffsetBefore api and
SimpleConsumer. The offset returned is at the log segment boundary. So it's
not going to match the specified time precisely.
For 2, you can configure a topic to be rolled by timestamp
(log.roll.hours and topic.log.roll.hours). Then
[
https://issues.apache.org/jira/browse/KAFKA-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13717977#comment-13717977
]
Jun Rao commented on KAFKA-987:
---
It seems that we don't need to update the offset map in
28 matches
Mail list logo