[jira] [Resolved] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-03 Thread Nishkam Ravi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nishkam Ravi resolved KAFKA-5528. - Resolution: Fixed > Error while reading topic, offset, partition info from process method >

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-03 Thread Nishkam Ravi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072997#comment-16072997 ] Nishkam Ravi commented on KAFKA-5528: - Thanks [~mjsax] for the pointer! That seems to have helped

[jira] [Assigned] (KAFKA-5245) KStream builder should capture serdes

2017-07-03 Thread anugrah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] anugrah reassigned KAFKA-5245: -- Assignee: (was: anugrah) > KStream builder should capture serdes >

[jira] [Assigned] (KAFKA-5245) KStream builder should capture serdes

2017-07-03 Thread anugrah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] anugrah reassigned KAFKA-5245: -- Assignee: Evgeny Veretennikov > KStream builder should capture serdes >

[jira] [Assigned] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2017-07-03 Thread Evgeny Veretennikov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-3539: -- Assignee: Evgeny Veretennikov (was: Manikumar) > KafkaProducer.send() may

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-07-03 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072228#comment-16072228 ] Yogesh BG commented on KAFKA-5545: -- Here I found out something that if the stream got closed successfully

[jira] [Comment Edited] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-07-03 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072228#comment-16072228 ] Yogesh BG edited comment on KAFKA-5545 at 7/3/17 10:27 AM: --- Here I found out

[jira] [Resolved] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-07-03 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-5530. --- Resolution: Not A Bug The main problem, at least what we had observed

[jira] [Created] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

2017-07-03 Thread Eno Thereska (JIRA)
Eno Thereska created KAFKA-5552: --- Summary: testTransactionalProducerTopicAuthorizationExceptionInCommit fails Key: KAFKA-5552 URL: https://issues.apache.org/jira/browse/KAFKA-5552 Project: Kafka

[jira] [Comment Edited] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-07-03 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072421#comment-16072421 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5530 at 7/3/17 1:15 PM:

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072596#comment-16072596 ] Matthias J. Sax commented on KAFKA-5530: Glad you could resolve your problem. We did change the

[jira] [Updated] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-07-03 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yogesh BG updated KAFKA-5545: - Attachment: kafkastreams.log I have attached the file. Whenever i get these debug log exceptions

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

2017-07-03 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072663#comment-16072663 ] Andrew Olson commented on KAFKA-1120: - [~wushujames] Can you retest with Kafka 0.11 to see if

[jira] [Commented] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072587#comment-16072587 ] Matthias J. Sax commented on KAFKA-5545: Can you do me a favor and attach the log file instead of

[jira] [Commented] (KAFKA-5528) Error while reading topic, offset, partition info from process method

2017-07-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072622#comment-16072622 ] Matthias J. Sax commented on KAFKA-5528: [~nravi] I guess the problem is, that you are using a

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

2017-07-03 Thread Sven Linstaedt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16072735#comment-16072735 ] Sven Linstaedt commented on KAFKA-2260: --- With KAFKA-4815 being released I still try to figure out,