[jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active (KIP-211)

[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519864#comment-16519864 ] ASF GitHub Bot commented on KAFKA-4682: --- hachikuji closed pull request #4896: KAFKA-4682: Revise

[jira] [Resolved] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException

[ https://issues.apache.org/jira/browse/KAFKA-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7082. Resolution: Fixed Reviewer: Jun Rao > Concurrent createTopics calls may throw

[jira] [Commented] (KAFKA-7082) Concurrent createTopics calls may throw NodeExistsException

[ https://issues.apache.org/jira/browse/KAFKA-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519850#comment-16519850 ] ASF GitHub Bot commented on KAFKA-7082: --- ijuma closed pull request #5259: KAFKA-7082: Concurrent

[jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519849#comment-16519849 ] Matthias J. Sax commented on KAFKA-7089: AFAIK, tools are considered public API, so I guess yes.

[jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519837#comment-16519837 ] Vahid Hashemian commented on KAFKA-7089: [~mjsax], do you think a KIP is required for this? >

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519827#comment-16519827 ] Matthias J. Sax commented on KAFKA-7041: Feel free to dig into this. On a high level, if should

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519812#comment-16519812 ] Nikki Thean commented on KAFKA-7041: [~mjsax] Thank you for taking the time to explain! I think I

[jira] [Assigned] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-6556: --- Assignee: John Roesler > allow to attach callbacks in kafka streams, to be triggered when a

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519694#comment-16519694 ] Corey Kasten commented on KAFKA-7012: - On behalf of [~rajadayalanvdms] and myself, thank you all! >

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519666#comment-16519666 ] Ismael Juma commented on KAFKA-7012: Dong has published 1.1.1 RC1 due to another issue which means

[jira] [Updated] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7012: --- Fix Version/s: (was: 1.1.2) 1.1.1 > Performance issue upgrading to kafka

[jira] [Assigned] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-7089: -- Assignee: Vahid Hashemian > Extend `kafka-consumer-groups.sh` to show "beginning

[jira] [Created] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

Matthias J. Sax created KAFKA-7089: -- Summary: Extend `kafka-consumer-groups.sh` to show "beginning offsets" Key: KAFKA-7089 URL: https://issues.apache.org/jira/browse/KAFKA-7089 Project: Kafka

[jira] [Assigned] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7075: Assignee: Nishanth Pradeep > Allow Topology#addGlobalStore to add a window store >

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519601#comment-16519601 ] Guozhang Wang commented on KAFKA-7075: -- Thanks [~nprad]. I've added you as the assignee. > Allow

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519600#comment-16519600 ] Guozhang Wang commented on KAFKA-7088: -- [~lgluchowski] The blocking code inside producer is: {code}

[jira] [Commented] (KAFKA-7079) ValueTransformer#transform does not pass the key

[ https://issues.apache.org/jira/browse/KAFKA-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519589#comment-16519589 ] Hashan Gayasri Udugahapattuwa commented on KAFKA-7079: -- [~mjsax] will do that.

[jira] [Commented] (KAFKA-7079) ValueTransformer#transform does not pass the key

[ https://issues.apache.org/jira/browse/KAFKA-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519575#comment-16519575 ] Matthias J. Sax commented on KAFKA-7079: [~hashan] We can leave this ticket open and update it to

[jira] [Updated] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7088: --- Labels: eos (was: ) > Kafka streams thread waits infinitely on transaction init >

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519572#comment-16519572 ] Matthias J. Sax commented on KAFKA-7088: According to the stack trace it hangs in the producer.

[jira] [Updated] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7088: --- Component/s: (was: streams) clients > Kafka streams thread waits

[jira] [Commented] (KAFKA-6977) Kafka Streams - java.lang.IllegalStateException: Unexpected error code 2 while fetching data

[ https://issues.apache.org/jira/browse/KAFKA-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519546#comment-16519546 ] Eugen Feller commented on KAFKA-6977: - [~guozhang] Cool. Makes sense. In my case, I wanted to avoid

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519542#comment-16519542 ] Ted Yu commented on KAFKA-7088: --- Is it possible to reproduce this behavior using 1.1.1 RC ? There have been

[jira] [Updated] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gluchowski updated KAFKA-7088: - Description: A kafka stream application thread stops processing without any feedback.

[jira] [Created] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

Lukasz Gluchowski created KAFKA-7088: Summary: Kafka streams thread waits infinitely on transaction init Key: KAFKA-7088 URL: https://issues.apache.org/jira/browse/KAFKA-7088 Project: Kafka

[jira] [Created] (KAFKA-7087) Option in TopicCommand to report not preferred leaders

Viktor Somogyi created KAFKA-7087: - Summary: Option in TopicCommand to report not preferred leaders Key: KAFKA-7087 URL: https://issues.apache.org/jira/browse/KAFKA-7087 Project: Kafka Issue

[jira] [Commented] (KAFKA-7059) Offer new constructor on ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519373#comment-16519373 ] ASF GitHub Bot commented on KAFKA-7059: --- matzew closed pull request #5228: KAFKA-7059 Offer new

[jira] [Updated] (KAFKA-7086) Kafka server process dies after try deleting old log files under Windows 10

[ https://issues.apache.org/jira/browse/KAFKA-7086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cezary Wagner updated KAFKA-7086: - Labels: windows (was: ) > Kafka server process dies after try deleting old log files under

[jira] [Created] (KAFKA-7086) Kafka server process dies after try deleting old log files under Windows 10

Cezary Wagner created KAFKA-7086: Summary: Kafka server process dies after try deleting old log files under Windows 10 Key: KAFKA-7086 URL: https://issues.apache.org/jira/browse/KAFKA-7086 Project:

[jira] [Created] (KAFKA-7085) Producer hangs on TimeoutException: Failed to update metadata after 60000 ms.

Martin Vysny created KAFKA-7085: --- Summary: Producer hangs on TimeoutException: Failed to update metadata after 6 ms. Key: KAFKA-7085 URL: https://issues.apache.org/jira/browse/KAFKA-7085 Project:

[jira] [Commented] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map

[ https://issues.apache.org/jira/browse/KAFKA-7084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519146#comment-16519146 ] ASF GitHub Bot commented on KAFKA-7084: --- chia7712 opened a new pull request #5261: KAFKA-7084

[jira] [Created] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map

Chia-Ping Tsai created KAFKA-7084: - Summary: NewTopicBuilder#config should accept Map rather than Map Key: KAFKA-7084 URL: https://issues.apache.org/jira/browse/KAFKA-7084 Project: Kafka

[jira] [Commented] (KAFKA-7083) maxTickMessages in ConsumerGroup option

[ https://issues.apache.org/jira/browse/KAFKA-7083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518999#comment-16518999 ] Manikumar commented on KAFKA-7083: -- looks like you are using Node.js Kafka client. Can you post this

[jira] [Commented] (KAFKA-7079) ValueTransformer#transform does not pass the key

[ https://issues.apache.org/jira/browse/KAFKA-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518992#comment-16518992 ] Hashan Gayasri Udugahapattuwa commented on KAFKA-7079: -- [~mjsax] Oh I wasn't of that

[jira] [Created] (KAFKA-7083) maxTickMessages in ConsumerGroup option

Rahul created KAFKA-7083: Summary: maxTickMessages in ConsumerGroup option Key: KAFKA-7083 URL: https://issues.apache.org/jira/browse/KAFKA-7083 Project: Kafka Issue Type: Bug Reporter: