[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=16027696#comment-16027696 ] Umesh Chaudhary commented on KAFKA-5093: No worries at all [~hachikuji] :) > Load only batch

[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=16027362#comment-16027362 ] Umesh Chaudhary commented on KAFKA-5093: Tried to co-relate it with KIP but was unable to locate

[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] [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] [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=16010242#comment-16010242 ] Umesh Chaudhary commented on KAFKA-5025: Hi [~ijuma], I executed the above test and observed that

[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=15996180#comment-15996180 ] Umesh Chaudhary commented on KAFKA-5171: [~guozhang] , Please review the PR. > TC should not

[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=15988235#comment-15988235 ] Umesh Chaudhary commented on KAFKA-5137: Indeed [~cotedm]. Even the *socketTimeoutMs* instance

[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=15982953#comment-15982953 ] Umesh Chaudhary edited comment on KAFKA-5025 at 4/28/17 4:53 AM: -

[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=15988198#comment-15988198 ] Umesh Chaudhary commented on KAFKA-5132: Sure [~damianguy]. Can understand :) > Abort long

[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=15986115#comment-15986115 ] Umesh Chaudhary commented on KAFKA-5132: Hi [~damianguy] , can I attempt this one? I need some

[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=15982953#comment-15982953 ] Umesh Chaudhary commented on KAFKA-5025: [~ijuma], taking this one to start my contribution to the

[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

[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=15980644#comment-15980644 ] Umesh Chaudhary commented on KAFKA-5114: IMHO, it has a co-relation with the previous statement:

[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=15979910#comment-15979910 ] Umesh Chaudhary commented on KAFKA-5098: I will reproduce and work on this. >

[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=15969873#comment-15969873 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] I tried to assign this to you but unfortunately

[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=15969805#comment-15969805 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] you can send a PR and for detailed steps you

[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=15968624#comment-15968624 ] Umesh Chaudhary commented on KAFKA-5049: Thanks [~junrao] for the pointers. While I was looking at

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

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

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

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

[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=15853424#comment-15853424 ] Umesh Chaudhary commented on KAFKA-4737: No worries. Thanks [~gwenshap] ! > Streams apps hang if

[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=15853422#comment-15853422 ] Umesh Chaudhary commented on KAFKA-4737: Hi [~gwenshap], does the intent is similar to KAFKA-4564?

[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=15813892#comment-15813892 ] Umesh Chaudhary edited comment on KAFKA-4569 at 1/10/17 9:18 AM: - Hi

[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=15814359#comment-15814359 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], [~ewencp], I am thinking to create a

[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=15813892#comment-15813892 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~ijuma], One observation regarding the case. I saw

[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=15793810#comment-15793810 ] Umesh Chaudhary commented on KAFKA-4564: Thank you [~ewencp]. > When the destination brokers are

[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=15792067#comment-15792067 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], please assign this to me. > When the

[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=15792055#comment-15792055 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~guozhang], I can work on this. Please assign this to

[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=15582838#comment-15582838 ] Umesh Chaudhary commented on KAFKA-4308: Sure Andrew, can you please assign this to me? >

[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=15582819#comment-15582819 ] Umesh Chaudhary commented on KAFKA-4308: Hi [~gwenshap], I would like to work on this. If

[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=15531969#comment-15531969 ] Umesh Chaudhary commented on KAFKA-4122: This one looks feasible. [~junrao] [~ewencp] Please

[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=15531931#comment-15531931 ] Umesh Chaudhary commented on KAFKA-4142: [~cmhillerman], Did you compare the size of both files

[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=15509565#comment-15509565 ] Umesh Chaudhary commented on KAFKA-4189: Yep, [Guozhang's

[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=15502860#comment-15502860 ] Umesh Chaudhary commented on KAFKA-4189: Is it similar to

[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=15424224#comment-15424224 ] Umesh Chaudhary commented on KAFKA-4053: I will do that. Please assign it to me. > Refactor