[jira] [Commented] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

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

[jira] [Resolved] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5731. Resolution: Fixed Fix Version/s: (was: 1.0.0) Issue resolved by pull request

[jira] [Commented] (KAFKA-5737) KafkaAdminClient thread should be daemon

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

[jira] [Created] (KAFKA-5737) KafkaAdminClient thread should be daemon

Colin P. McCabe created KAFKA-5737: -- Summary: KafkaAdminClient thread should be daemon Key: KAFKA-5737 URL: https://issues.apache.org/jira/browse/KAFKA-5737 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128011#comment-16128011 ] Guozhang Wang edited comment on KAFKA-5440 at 8/15/17 10:54 PM:

[jira] [Created] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down

Konstantine Karantasis created KAFKA-5736: - Summary: Improve error message in Connect when all kafka brokers are down Key: KAFKA-5736 URL: https://issues.apache.org/jira/browse/KAFKA-5736

[jira] [Updated] (KAFKA-5735) Client-ids are not handled consistently by clients and broker

[ https://issues.apache.org/jira/browse/KAFKA-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5735: -- Description: At the moment, Java clients expect client-ids to use a limited set of characters

[jira] [Commented] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

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

[jira] [Commented] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

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

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127744#comment-16127744 ] Dong Lin commented on KAFKA-5663: - [~cmccabe] It appears that the bug in ConsoleConsumer has been

[jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127737#comment-16127737 ] Manikumar commented on KAFKA-5714: -- By default, the SSL user name will be of the form

[jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127711#comment-16127711 ] Alla Tumarkin commented on KAFKA-5714: -- If I have super.users=User:CN=Unknown, OU=Unknown, O=Unknown,

[jira] [Resolved] (KAFKA-2283) scheduler exception on non-controller node when shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2283. -- Resolution: Fixed > scheduler exception on non-controller node when shutdown >

[jira] [Resolved] (KAFKA-2220) Improvement: Could we support rewind by time ?

[ https://issues.apache.org/jira/browse/KAFKA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2220. -- Resolution: Fixed This got fixed in KAFKA-4743 / KIP-122. > Improvement: Could we support rewind by

[jira] [Comment Edited] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127680#comment-16127680 ] Soumabrata Chakraborty edited comment on KAFKA-5072 at 8/15/17 6:31 PM:

[jira] [Commented] (KAFKA-5072) Kafka topics should allow custom metadata configs within some config namespace

[ https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127680#comment-16127680 ] Soumabrata Chakraborty commented on KAFKA-5072: --- Hi [~ondrej.tomcik] - Thanks for reaching

[jira] [Commented] (KAFKA-2206) Add AlterConfig and DescribeConfig requests to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-2206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127676#comment-16127676 ] Manikumar commented on KAFKA-2206: -- this looks like is a duplicate of KIP-133/ KAFKA-3267. If so, we can

[jira] [Updated] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

[ https://issues.apache.org/jira/browse/KAFKA-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5727: - Fix Version/s: 0.11.0.1 > Add the archetype project along with "write applications" web docs. >

[jira] [Comment Edited] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127637#comment-16127637 ] Tommy Becker edited comment on KAFKA-5440 at 8/15/17 5:56 PM: -- To answer my

[jira] [Commented] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127637#comment-16127637 ] Tommy Becker commented on KAFKA-5440: - To answer my own question, from what I can tell the PR for

[jira] [Resolved] (KAFKA-1832) Async Producer will cause 'java.net.SocketException: Too many open files' when broker host does not exist

[ https://issues.apache.org/jira/browse/KAFKA-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1832. -- Resolution: Fixed Fixed in KAFKA-1041 > Async Producer will cause 'java.net.SocketException: Too many

[jira] [Resolved] (KAFKA-1821) Example shell scripts broken

[ https://issues.apache.org/jira/browse/KAFKA-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1821. -- Resolution: Fixed It is working in newer Kafka versions. > Example shell scripts broken >

[jira] [Updated] (KAFKA-5603) Streams should not abort transaction when closing zombie task

[ https://issues.apache.org/jira/browse/KAFKA-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5603: -- Fix Version/s: (was: 0.11.0.1) 0.11.0.2 > Streams should not abort transaction

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5054: -- Fix Version/s: (was: 0.11.0.1) 1.0.0 > ChangeLoggingKeyValueByteStore delete and

[jira] [Commented] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127574#comment-16127574 ] Randall Hauch commented on KAFKA-5535: -- [~hachikuji], can you please backport this to the {{0.11.0}}

[jira] [Updated] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5731: - Fix Version/s: 0.11.0.1 > Connect WorkerSinkTask out of order offset commit can lead to

[jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127513#comment-16127513 ] Manikumar commented on KAFKA-5714: -- ZK based topic creation/deletion doesn't go through ACL

[jira] [Assigned] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka

[ https://issues.apache.org/jira/browse/KAFKA-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5679: --- Assignee: Rajini Sivaram (was: Apurva Mehta) > Add logging to distinguish between

[jira] [Commented] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka

[ https://issues.apache.org/jira/browse/KAFKA-5679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127451#comment-16127451 ] Apurva Mehta commented on KAFKA-5679: - Assigning to [~rsivaram] since she already has a patch for

[jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient

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

[jira] [Comment Edited] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127316#comment-16127316 ] Tommy Becker edited comment on KAFKA-5440 at 8/15/17 2:41 PM: -- Any update on

[jira] [Commented] (KAFKA-5440) Kafka Streams report state RUNNING even if all threads are dead

[ https://issues.apache.org/jira/browse/KAFKA-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127316#comment-16127316 ] Tommy Becker commented on KAFKA-5440: - Any update on this? We're seeing the same behavior and I though

[jira] [Created] (KAFKA-5735) Client-ids are not handled consistently by clients and broker

Rajini Sivaram created KAFKA-5735: - Summary: Client-ids are not handled consistently by clients and broker Key: KAFKA-5735 URL: https://issues.apache.org/jira/browse/KAFKA-5735 Project: Kafka

[jira] [Commented] (KAFKA-5718) Better document what LogAppendTime means

[ https://issues.apache.org/jira/browse/KAFKA-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127086#comment-16127086 ] Umesh Chaudhary commented on KAFKA-5718: [~cotedm] Message Format seems correct section to place

[jira] [Assigned] (KAFKA-5718) Better document what LogAppendTime means

[ https://issues.apache.org/jira/browse/KAFKA-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5718: -- Assignee: Umesh Chaudhary > Better document what LogAppendTime means >

[jira] [Commented] (KAFKA-5734) Heap (Old generation space) gradually increase

[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127078#comment-16127078 ] Manikumar commented on KAFKA-5734: -- We can use JMAP command to output a histogram of java object heap.

[jira] [Created] (KAFKA-5734) Heap (Old generation space) gradually increase

jang created KAFKA-5734: --- Summary: Heap (Old generation space) gradually increase Key: KAFKA-5734 URL: https://issues.apache.org/jira/browse/KAFKA-5734 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener

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

[jira] [Commented] (KAFKA-5679) Add logging to distinguish between internally and externally initiated shutdown of Kafka

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