[jira] [Commented] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand

2016-12-18 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15760443#comment-15760443 ] Vahid Hashemian commented on KAFKA-3853: [~jeffwidman] Yes, it did pass. But, unfo

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

2016-12-18 Thread Becket Qin
@Jason Yes, second thought on the number of messages included, the offset delta will probably be sufficient. The use case I encounter before for number of messages in a message set is an embedded mirror maker on the destination broker side which fetches message directly from the source cluster. Id

[GitHub] kafka pull request #2274: Implement topic config for internal topics

2016-12-18 Thread sjmittal
GitHub user sjmittal opened a pull request: https://github.com/apache/kafka/pull/2274 Implement topic config for internal topics You can merge this pull request into a Git repository by running: $ git pull https://github.com/sjmittal/kafka sm Alternatively you can review and

[jira] [Commented] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand

2016-12-18 Thread Jeff Widman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759588#comment-15759588 ] Jeff Widman commented on KAFKA-3853: Did the KIP get the missing vote required to pass

Re: [DISCUSS] KIP-82 - Add Record Headers

2016-12-18 Thread Matthias J. Sax
The details about headers for control messages are still to define. But yes, the idea is to have some common default behavior that clients would need to implement. The point is, that "regular headers" add meta data to regular messages. Thus, those messages will be returned to the user via .poll().

[jira] [Commented] (KAFKA-4555) Using Hamcrest for easy intent expression in tests

2016-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759489#comment-15759489 ] ASF GitHub Bot commented on KAFKA-4555: --- GitHub user rekhajoshm opened a pull reques

[GitHub] kafka pull request #2273: KAFKA-4555: Using Hamcrest for expressive intent i...

2016-12-18 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/kafka/pull/2273 KAFKA-4555: Using Hamcrest for expressive intent in tests - Adding hamcrest in gradle files - Using hamcrest in couple of tests - SourceTaskOffsetCommitterTest, MetadataTest You can merge th

[jira] [Created] (KAFKA-4555) Using Hamcrest for easy intent expression in tests

2016-12-18 Thread Rekha Joshi (JIRA)
Rekha Joshi created KAFKA-4555: -- Summary: Using Hamcrest for easy intent expression in tests Key: KAFKA-4555 URL: https://issues.apache.org/jira/browse/KAFKA-4555 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-4527) Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages

2016-12-18 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759269#comment-15759269 ] Roger Hoover commented on KAFKA-4527: - Happened again: http://confluent-systest.s3-w

[jira] [Commented] (KAFKA-3808) Transient failure in ReplicaVerificationToolTest

2016-12-18 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759266#comment-15759266 ] Roger Hoover commented on KAFKA-3808: - Happened again: http://confluent-systest.s3-w

[jira] [Commented] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

2016-12-18 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759264#comment-15759264 ] Roger Hoover commented on KAFKA-4166: - Similar failure: http://confluent-systest.s3-w

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

2016-12-18 Thread Roger Hoover (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759260#comment-15759260 ] Roger Hoover commented on KAFKA-4526: - Thanks, [~apurva] > Transient failure in Throt

Re: log.flush.interval.messages setting of Kafka 0.9.0.0

2016-12-18 Thread Json Tu
Would be grateful to hear opinions from experts out there. Thanks in advance > 在 2016年12月16日，下午6:17，Json Tu 写道： > > Hi all, > we have a cluster of 0.9.0.0 with 3 nodes, we have a topic with 3 > replicas, and send it with ack -1, our sending latency is avg 7ms. I prepare > to optimize pe

[jira] [Resolved] (KAFKA-3841) MirrorMaker topic renaming

2016-12-18 Thread Ning Zhang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ning Zhang resolved KAFKA-3841. --- Resolution: Won't Fix > MirrorMaker topic renaming > -- > > Ke

[jira] [Resolved] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

2016-12-18 Thread James Cheng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng resolved KAFKA-4187. Resolution: Resolved [~m...@vrischmann.me] was able to use MirrorMakerMessageHandler to solve this.