[jira] [Commented] (KAFKA-5556) KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074389#comment-16074389 ] Umesh Chaudhary commented on KAFKA-5556: [~damianguy], I can work on this. > Kaf

[jira] [Created] (KAFKA-5557) Using a logPrefix inside the StreamPartitionAssignor

Paolo Patierno created KAFKA-5557: - Summary: Using a logPrefix inside the StreamPartitionAssignor Key: KAFKA-5557 URL: https://issues.apache.org/jira/browse/KAFKA-5557 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-5537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074428#comment-16074428 ] Rajini Sivaram commented on KAFKA-5537: --- [~michael.andre.pearce] I have run your tes

[jira] [Commented] (KAFKA-5519) Support for multiple certificates in a single keystore

[ https://issues.apache.org/jira/browse/KAFKA-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074427#comment-16074427 ] Tom Bentley commented on KAFKA-5519: Can you explain why having a keystore per compone

[jira] [Commented] (KAFKA-5557) Using a logPrefix inside the StreamPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-5557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074480#comment-16074480 ] ASF GitHub Bot commented on KAFKA-5557: --- GitHub user ppatierno opened a pull request

[jira] [Updated] (KAFKA-5556) KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5556: --- Fix Version/s: 0.10.2.1 0.11.0.1 > KafkaConsumer throws: java.lang.IllegalStateExce

[jira] [Updated] (KAFKA-5556) KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5556: --- Priority: Critical (was: Major) > KafkaConsumer throws: java.lang.IllegalStateException: > Attempt to

[jira] [Assigned] (KAFKA-5556) KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5556: -- Assignee: Umesh Chaudhary > KafkaConsumer.commitSync throws IllegalStateException: Attempt to r

[jira] [Updated] (KAFKA-5556) KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5556: --- Summary: KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from fut

[jira] [Updated] (KAFKA-5556) KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5556: --- Fix Version/s: (was: 0.10.2.1) 0.10.2.2 > KafkaConsumer.commitSync throws Illeg

[jira] [Created] (KAFKA-5558) can not connect to the unsecure port after config SASL/PLAIN

zhu fangbo created KAFKA-5558: - Summary: can not connect to the unsecure port after config SASL/PLAIN Key: KAFKA-5558 URL: https://issues.apache.org/jira/browse/KAFKA-5558 Project: Kafka Issue T

[jira] [Updated] (KAFKA-5558) can not connect to the unsecure port after config SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-5558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo updated KAFKA-5558: -- Issue Type: Bug (was: New Feature) > can not connect to the unsecure port after config SASL/PLAIN > ---

[jira] [Commented] (KAFKA-5558) can not connect to the unsecure port after config SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-5558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074537#comment-16074537 ] Rajini Sivaram commented on KAFKA-5558: --- The error indicates PLAINTEXT producer has

[jira] [Commented] (KAFKA-5558) can not connect to the unsecure port after config SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-5558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074567#comment-16074567 ] zhu fangbo commented on KAFKA-5558: --- Rajini Sivaram , Thanks for your advise, it re

[jira] [Commented] (KAFKA-5556) KafkaConsumer.commitSync throws IllegalStateException: Attempt to retrieve exception from future which hasn't failed

[ https://issues.apache.org/jira/browse/KAFKA-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074573#comment-16074573 ] ASF GitHub Bot commented on KAFKA-5556: --- GitHub user umesh9794 opened a pull request

[jira] [Resolved] (KAFKA-5558) can not connect to the unsecure port after config SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-5558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo resolved KAFKA-5558. --- Resolution: Fixed this is not a bug > can not connect to the unsecure port after config SASL/PLAIN >

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 11:03 AM: *I

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 11:03 AM: *I

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 11:06 AM: *I

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 11:18 AM: *I

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 11:26 AM: *I

[jira] [Assigned] (KAFKA-5255) Auto generate request/response classes

[ https://issues.apache.org/jira/browse/KAFKA-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley reassigned KAFKA-5255: -- Assignee: Tom Bentley > Auto generate request/response classes > --

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074714#comment-16074714 ] Evgeny Veretennikov commented on KAFKA-5503: [~hachikuji], part of call stack

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 1:04 PM: --- *Inv

[jira] [Comment Edited] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery edited comment on KAFKA-5515 at 7/5/17 1:04 PM: --- *Inv

[jira] [Commented] (KAFKA-5500) it is impossible to have custom Login Modules for PLAIN SASL mechanism

[ https://issues.apache.org/jira/browse/KAFKA-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16074720#comment-16074720 ] Rajini Sivaram commented on KAFKA-5500: --- Kafka's implementation of {{PlainLoginModul

[jira] [Assigned] (KAFKA-4249) Document how to customize GC logging options for broker

[ https://issues.apache.org/jira/browse/KAFKA-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov reassigned KAFKA-4249: -- Assignee: Tom Bentley > Document how to customize GC logging options for broker

[jira] [Resolved] (KAFKA-3823) QuickStart documentation is still showing MirrorMakers supports more than one consumer.config

[ https://issues.apache.org/jira/browse/KAFKA-3823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov resolved KAFKA-3823. Resolution: Fixed Closed issue, as [~tombentley] suggested. > QuickStart documentat

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075005#comment-16075005 ] Damian Guy commented on KAFKA-4609: --- This was partially fixed by https://cwiki.apache.o

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075053#comment-16075053 ] Damian Guy commented on KAFKA-5545: --- As you suggested, it would see that the first Kafka

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075056#comment-16075056 ] Matthias J. Sax commented on KAFKA-5070: I was working on https://issues.apache.or

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075061#comment-16075061 ] Yogesh BG commented on KAFKA-5545: -- I see. But what could be the problems in closing the

[jira] [Commented] (KAFKA-5519) Support for multiple certificates in a single keystore

[ https://issues.apache.org/jira/browse/KAFKA-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075164#comment-16075164 ] Alla Tumarkin commented on KAFKA-5519: -- I wouldn't call it problematic: I just imagin

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

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5528: > Error while reading topic, offset, partition info from process method > --

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

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5528. Resolution: Not A Bug > Error while reading topic, offset, partition info from process metho

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

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075191#comment-16075191 ] Matthias J. Sax commented on KAFKA-5528: Added FAQ: https://cwiki.apache.org/conf

[jira] [Updated] (KAFKA-5525) Streams reset tool should have same console output with or without dry-run

[ https://issues.apache.org/jira/browse/KAFKA-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5525: - Component/s: streams > Streams reset tool should have same console output with or without dry-run

[jira] [Commented] (KAFKA-5525) Streams reset tool should have same console output with or without dry-run

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075511#comment-16075511 ] Guozhang Wang commented on KAFKA-5528: -- Thanks [~mjsax] for adding the FAQ, I think t

[jira] [Commented] (KAFKA-3331) Refactor TopicCommand to make it testable and add unit tests

[ https://issues.apache.org/jira/browse/KAFKA-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075525#comment-16075525 ] Gwen Shapira commented on KAFKA-3331: - +1, that would be awesome Since it is via a nor

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075541#comment-16075541 ] Guozhang Wang commented on KAFKA-5545: -- [~yogeshbelur] In your code snippet it seems

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075541#comment-16075541 ] Guozhang Wang edited comment on KAFKA-5545 at 7/5/17 10:34 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075558#comment-16075558 ] Guozhang Wang commented on KAFKA-5545: -- Which config of the {{connection timeout}} th

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075624#comment-16075624 ] Ankush Puri commented on KAFKA-4936: [~damianguy] [~ijuma] Any plans of this feature b

[jira] [Updated] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4601: - Description: Consider the following DSL: {code} Stream source = builder.stream(Serdes.String(),

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075691#comment-16075691 ] Matthias J. Sax commented on KAFKA-4936: No concrete roadmap atm. But if anybody w

[jira] [Created] (KAFKA-5559) Metrics should throw if two client registers with same ID

Matthias J. Sax created KAFKA-5559: -- Summary: Metrics should throw if two client registers with same ID Key: KAFKA-5559 URL: https://issues.apache.org/jira/browse/KAFKA-5559 Project: Kafka I

[jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID

[ https://issues.apache.org/jira/browse/KAFKA-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075784#comment-16075784 ] TAO XIAO commented on KAFKA-5559: - Does this PR suggest we need to use different {{client.

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

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

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075940#comment-16075940 ] Matthias J. Sax commented on KAFKA-5070: [~dnagarajan], [~shoyebpathan], [~kchen]

[jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075943#comment-16075943 ] Matthias J. Sax commented on KAFKA-5397: [~jozi-k] KAFKA-5167 got merged into {{tr

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075945#comment-16075945 ] Yogesh BG commented on KAFKA-5545: -- Hey setupDiscovery is scheduled thread, having logic

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

[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075945#comment-16075945 ] Yogesh BG edited comment on KAFKA-5545 at 7/6/17 5:16 AM: -- Hey s

[jira] [Commented] (KAFKA-5557) Using a logPrefix inside the StreamPartitionAssignor

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

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16076052#comment-16076052 ] Sönke Liebau commented on KAFKA-4827: - There is a few more special characters that cau