Re: Possible StreamingConfig Bug

Yes, that is the case from my usage. FWIW I have a Jira ticket (KAFKA-2902) and have submitted a PR (#596) to address the issue. Thanks, Bill > On Nov 28, 2015, at 1:27 AM, Guozhang Wang wrote: > > I think the problem is that "getConsumerConfigs" called in StreamThread. >

[jira] [Commented] (KAFKA-2891) Gaps in messages delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030455#comment-15030455 ] Ben Stopford commented on KAFKA-2891: - Sorry [~hachikuji]- typo - should have said "implies the

[jira] [Comment Edited] (KAFKA-2891) Gaps in messages delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030082#comment-15030082 ] Ben Stopford edited comment on KAFKA-2891 at 11/28/15 10:32 AM: One more

[jira] [Created] (KAFKA-2904) Consumer Fails to Reconnect after 30s post restarts

Ben Stopford created KAFKA-2904: --- Summary: Consumer Fails to Reconnect after 30s post restarts Key: KAFKA-2904 URL: https://issues.apache.org/jira/browse/KAFKA-2904 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-2905) System test for rolling upgrade to enable ZooKeeper ACLs with SASL

Flavio Junqueira created KAFKA-2905: --- Summary: System test for rolling upgrade to enable ZooKeeper ACLs with SASL Key: KAFKA-2905 URL: https://issues.apache.org/jira/browse/KAFKA-2905 Project:

[jira] [Updated] (KAFKA-2904) Consumer Fails to Reconnect after 30s post restarts

[ https://issues.apache.org/jira/browse/KAFKA-2904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford updated KAFKA-2904: Attachment: 2015-11-27--001 (1).tar.gz > Consumer Fails to Reconnect after 30s post restarts >

[jira] [Commented] (KAFKA-2897) Class NIOServerCnxn$Factory not found due to mismatch in dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030475#comment-15030475 ] Yuval Steinberg commented on KAFKA-2897: Then how come not only that is seems to work fine for us

[jira] [Commented] (KAFKA-2732) Add test cases with ZK Auth, SASL and SSL

[ https://issues.apache.org/jira/browse/KAFKA-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030581#comment-15030581 ] ASF GitHub Bot commented on KAFKA-2732: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-2732) Add test cases with ZK Auth, SASL and SSL

[ https://issues.apache.org/jira/browse/KAFKA-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2732. Resolution: Fixed Issue resolved by pull request 410 [https://github.com/apache/kafka/pull/410] > Add test

[GitHub] kafka pull request: KAFKA-2732: Add class for ZK Auth.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/410 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk8 #191

See Changes: [junrao] KAFKA-2732; Add class for ZK Auth. -- [...truncated 4461 lines...] org.apache.kafka.connect.json.JsonConverterTest > timeToJson PASSED

Doubt on Kafka storage and Consuming messages

Hi , I am new in Kafka . I went through some docments to understand Kafka. I have some questions. Please help me to understand 1> Kafka storage: What is the physical existing of segment file ? What do you mean by "flushing segment file to disk"? One of the document mentioned -- "A message is only

Re: Release source doesn't contain .gitignore

Hi Edward, I am not sure what the best practice is. Since it is checked in as part of the project, I considered it effectively part of its source. I suspect the method for collecting and taring the source files excluded it by accident (perhaps by many of these projects) and is something that

Build failed in Jenkins: kafka-trunk-jdk7 #862

See Changes: [junrao] KAFKA-2732; Add class for ZK Auth. -- [...truncated 2795 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile PASSED