[jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15792055#comment-15792055 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~guozhang], I can work on this. Pleas

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15792067#comment-15792067 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], please assign this to me.

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15793810#comment-15793810 ] Umesh Chaudhary commented on KAFKA-4564: Thank you [~ewencp]. > When the destinat

[jira] [Commented] (KAFKA-5057) "Big Message Log"

[ https://issues.apache.org/jira/browse/KAFKA-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965615#comment-15965615 ] Umesh Chaudhary commented on KAFKA-5057: [~gwenshap] currently we have "max.reques

[jira] [Commented] (KAFKA-5057) "Big Message Log"

[ https://issues.apache.org/jira/browse/KAFKA-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968580#comment-15968580 ] Umesh Chaudhary commented on KAFKA-5057: Understood and yes this is a good idea to

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968624#comment-15968624 ] Umesh Chaudhary commented on KAFKA-5049: Thanks [~junrao] for the pointers. While

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969805#comment-15969805 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] you can send a PR and for detai

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969873#comment-15969873 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] I tried to assign this to you b

[jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979910#comment-15979910 ] Umesh Chaudhary commented on KAFKA-5098: I will reproduce and work on this. > Ka

[jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813892#comment-15813892 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~ijuma], One observation regarding th

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814359#comment-15814359 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], [~ewencp], I am thinking

[jira] [Comment Edited] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813892#comment-15813892 ] Umesh Chaudhary edited comment on KAFKA-4569 at 1/10/17 9:18 AM: ---

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853422#comment-15853422 ] Umesh Chaudhary commented on KAFKA-4737: Hi [~gwenshap], does the intent is simila

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853424#comment-15853424 ] Umesh Chaudhary commented on KAFKA-4737: No worries. Thanks [~gwenshap] ! > Strea

[jira] [Commented] (KAFKA-4053) Refactor TopicCommand to remove redundant if/else statements

[ https://issues.apache.org/jira/browse/KAFKA-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424224#comment-15424224 ] Umesh Chaudhary commented on KAFKA-4053: I will do that. Please assign it to me.

[jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled

[ https://issues.apache.org/jira/browse/KAFKA-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502860#comment-15502860 ] Umesh Chaudhary commented on KAFKA-4189: Is it similar to [KAFKA-1894|https://issu

[jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled

[ https://issues.apache.org/jira/browse/KAFKA-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509565#comment-15509565 ] Umesh Chaudhary commented on KAFKA-4189: Yep, [Guozhang's comment|https://issues.

[jira] [Commented] (KAFKA-4142) Log files in /data dir date modified keeps being updated?

[ https://issues.apache.org/jira/browse/KAFKA-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531931#comment-15531931 ] Umesh Chaudhary commented on KAFKA-4142: [~cmhillerman], Did you compare the size

[jira] [Commented] (KAFKA-4122) Consumer startup swallows DNS resolution exception and infinitely retries

[ https://issues.apache.org/jira/browse/KAFKA-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531969#comment-15531969 ] Umesh Chaudhary commented on KAFKA-4122: This one looks feasible. [~junrao] [~ewe

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582819#comment-15582819 ] Umesh Chaudhary commented on KAFKA-4308: Hi [~gwenshap], I would like to work on t

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582838#comment-15582838 ] Umesh Chaudhary commented on KAFKA-4308: Sure Andrew, can you please assign this t

[jira] [Commented] (KAFKA-5114) Clarify meaning of logs in Introduction: Topics and Logs

[ https://issues.apache.org/jira/browse/KAFKA-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980644#comment-15980644 ] Umesh Chaudhary commented on KAFKA-5114: IMHO, it has a co-relation with the previ

[jira] [Assigned] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5025: -- Assignee: Umesh Chaudhary > FetchRequestTest should use batches with more than one mess

[jira] [Commented] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982953#comment-15982953 ] Umesh Chaudhary commented on KAFKA-5025: [~ijuma], taking this one to start my con

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986115#comment-15986115 ] Umesh Chaudhary commented on KAFKA-5132: Hi [~damianguy] , can I attempt this one?

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988198#comment-15988198 ] Umesh Chaudhary commented on KAFKA-5132: Sure [~damianguy]. Can understand :) > A

[jira] [Comment Edited] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982953#comment-15982953 ] Umesh Chaudhary edited comment on KAFKA-5025 at 4/28/17 4:53 AM: ---

[jira] [Commented] (KAFKA-5137) Controlled shutdown timeout message improvement

[ https://issues.apache.org/jira/browse/KAFKA-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988235#comment-15988235 ] Umesh Chaudhary commented on KAFKA-5137: Indeed [~cotedm]. Even the *socketTimeout

[jira] [Commented] (KAFKA-5171) TC should not accept empty string transactional id

[ https://issues.apache.org/jira/browse/KAFKA-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996180#comment-15996180 ] Umesh Chaudhary commented on KAFKA-5171: [~guozhang] , Please review the PR. > T

[jira] [Commented] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010242#comment-16010242 ] Umesh Chaudhary commented on KAFKA-5025: Hi [~ijuma], I executed the above test an

[jira] [Assigned] (KAFKA-4660) Improve test coverage KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-4660: -- Assignee: Umesh Chaudhary > Improve test coverage KafkaStreams > --

[jira] [Assigned] (KAFKA-5171) TC should not accept empty string transactional id

[ https://issues.apache.org/jira/browse/KAFKA-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5171: -- Assignee: Umesh Chaudhary > TC should not accept empty string transactional id > --

[jira] [Commented] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027362#comment-16027362 ] Umesh Chaudhary commented on KAFKA-5093: Tried to co-relate it with KIP but was un

[jira] [Commented] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027696#comment-16027696 ] Umesh Chaudhary commented on KAFKA-5093: No worries at all [~hachikuji] :) > Load