[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885855#comment-16885855 ] Omkar Mestry commented on KAFKA-7245: - So should I start making changes in code for removing the

[jira] [Comment Edited] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885795#comment-16885795 ] Richard Yu edited comment on KAFKA-7711 at 7/16/19 3:01 AM: [~hachikuji] I

[jira] [Commented] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885795#comment-16885795 ] Richard Yu commented on KAFKA-7711: --- [~hachikuji] I think I've seen this issue come up multiple times

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885767#comment-16885767 ] Matthias J. Sax commented on KAFKA-8555:

[jira] [Created] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

Matthias J. Sax created KAFKA-8672: -- Summary: RebalanceSourceConnectorsIntegrationTest#testReconfigConnector Key: KAFKA-8672 URL: https://issues.apache.org/jira/browse/KAFKA-8672 Project: Kafka

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885740#comment-16885740 ] Matthias J. Sax commented on KAFKA-8412: Just cycling back to this. I am not sure if we should

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885726#comment-16885726 ] ASF GitHub Bot commented on KAFKA-8179: --- ableegoldman commented on pull request #7095: KAFKA-8179:

[jira] [Commented] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

[ https://issues.apache.org/jira/browse/KAFKA-8671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885709#comment-16885709 ] Matthias J. Sax commented on KAFKA-8671: This issue might be related to KAFKA-5998 – if we cannot

[jira] [Resolved] (KAFKA-8637) WriteBatch objects leak off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8637. Resolution: Fixed > WriteBatch objects leak off-heap memory >

[jira] [Commented] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885707#comment-16885707 ] Matthias J. Sax commented on KAFKA-8650: Splitting out initialization is not easy. The problem is

[jira] [Created] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

Alex Leung created KAFKA-8671: - Summary: NullPointerException occurs if topic associated with GlobalKTable changes Key: KAFKA-8671 URL: https://issues.apache.org/jira/browse/KAFKA-8671 Project: Kafka

[jira] [Commented] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885704#comment-16885704 ] ASF GitHub Bot commented on KAFKA-8670: --- wyuka commented on pull request #7094: KAFKA-8670 and

[jira] [Commented] (KAFKA-8637) WriteBatch objects leak off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885702#comment-16885702 ] ASF GitHub Bot commented on KAFKA-8637: --- guozhangwang commented on pull request #7050: KAFKA-8637:

[jira] [Updated] (KAFKA-8620) Race condition in StreamThread state change

[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8620: --- Fix Version/s: 2.3.1 2.2.2 2.1.2 > Race condition in

[jira] [Updated] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8602: - Fix Version/s: 2.4.0 > StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885676#comment-16885676 ] ASF GitHub Bot commented on KAFKA-8602: --- bbejeck commented on pull request #7092: KAFKA-8602:

[jira] [Commented] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885667#comment-16885667 ] ASF GitHub Bot commented on KAFKA-8670: --- wyuka commented on pull request #7091: KAFKA-8670: Fix

[jira] [Commented] (KAFKA-8620) Race condition in StreamThread state change

[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885655#comment-16885655 ] ASF GitHub Bot commented on KAFKA-8620: --- mjsax commented on pull request #7021: KAFKA-8620: fix NPE

[jira] [Updated] (KAFKA-8620) Race condition in StreamThread state change

[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8620: --- Affects Version/s: 2.1.0 > Race condition in StreamThread state change >

[jira] [Commented] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885640#comment-16885640 ] Raman Gupta commented on KAFKA-8650: There is also a related API change / improvement that I believe

[jira] [Commented] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885632#comment-16885632 ] ASF GitHub Bot commented on KAFKA-8670: --- wyuka commented on pull request #7091: KAFKA-8670: Fix

[jira] [Updated] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

[ https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-8638: -- Description: Currently, the kafka preferred leader election will pick the broker_id in the

[jira] [Resolved] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8602. Resolution: Fixed > StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic >

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885595#comment-16885595 ] ASF GitHub Bot commented on KAFKA-8602: --- bbejeck commented on pull request #7008: KAFKA-8602: Fix

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885498#comment-16885498 ] James Ritt commented on KAFKA-4212: --- Thanks [~ableegoldman] & [~mjsax], you both make good points.

[jira] [Commented] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

[ https://issues.apache.org/jira/browse/KAFKA-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885489#comment-16885489 ] Brian commented on KAFKA-7931: -- Would love to see a patch. How do you know you've solved the issue? Are you

[jira] [Updated] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tirtha Chatterjee updated KAFKA-8670: - Summary: kafka-topics.sh shows IllegalArgumentException when describing all topics if no

[jira] [Updated] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tirtha Chatterjee updated KAFKA-8670: - Description: When trying to describe all  the kafka-topics.sh utility, a user would run

[jira] [Commented] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885476#comment-16885476 ] Tirtha Chatterjee commented on KAFKA-8670: -- This bug was introduced as part of this commit

[jira] [Commented] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist

[ https://issues.apache.org/jira/browse/KAFKA-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885474#comment-16885474 ] Tirtha Chatterjee commented on KAFKA-8670: -- This issue is distinct from

[jira] [Created] (KAFKA-8670) kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist

Tirtha Chatterjee created KAFKA-8670: Summary: kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist Key: KAFKA-8670 URL:

[jira] [Updated] (KAFKA-8669) Add java security providers in Kafka Security config

[ https://issues.apache.org/jira/browse/KAFKA-8669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sandeep updated KAFKA-8669: --- Description: Currently kafka supports ssl.keymanager.algorithm and ssl.trustmanager.algorithm

[jira] [Created] (KAFKA-8669) Add java security providers in Kafka Security config

Sai Sandeep created KAFKA-8669: -- Summary: Add java security providers in Kafka Security config Key: KAFKA-8669 URL: https://issues.apache.org/jira/browse/KAFKA-8669 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885438#comment-16885438 ] Matthias J. Sax commented on KAFKA-8613: [~LillianY] – thanks for you interest. However, this

[jira] [Created] (KAFKA-8668) Improve broker shutdown time

Zhanxiang (Patrick) Huang created KAFKA-8668: Summary: Improve broker shutdown time Key: KAFKA-8668 URL: https://issues.apache.org/jira/browse/KAFKA-8668 Project: Kafka Issue

[jira] [Created] (KAFKA-8667) Improve leadership transition time

Zhanxiang (Patrick) Huang created KAFKA-8667: Summary: Improve leadership transition time Key: KAFKA-8667 URL: https://issues.apache.org/jira/browse/KAFKA-8667 Project: Kafka

[jira] [Commented] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

[ https://issues.apache.org/jira/browse/KAFKA-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885435#comment-16885435 ] Matthias J. Sax commented on KAFKA-8650: It's a first time report / request. Hence, it does not

[jira] [Created] (KAFKA-8666) Improve Documentation on usage of Materialized config object

Bill Bejeck created KAFKA-8666: -- Summary: Improve Documentation on usage of Materialized config object Key: KAFKA-8666 URL: https://issues.apache.org/jira/browse/KAFKA-8666 Project: Kafka

[jira] [Created] (KAFKA-8665) WorkerSourceTask race condition when rebalance occurs before task has started

Chris Cranford created KAFKA-8665: - Summary: WorkerSourceTask race condition when rebalance occurs before task has started Key: KAFKA-8665 URL: https://issues.apache.org/jira/browse/KAFKA-8665

[jira] [Commented] (KAFKA-8646) Materialized.withLoggingDisabled() does not disable changelog topics creation

[ https://issues.apache.org/jira/browse/KAFKA-8646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885391#comment-16885391 ] Bill Bejeck commented on KAFKA-8646: Thanks again [~jmhostalet] for reporting this. After looking

[jira] [Commented] (KAFKA-8604) kafka log dir was marked as offline because of deleting segments of __consumer_offsets failed

[ https://issues.apache.org/jira/browse/KAFKA-8604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885316#comment-16885316 ] Alex Bertzeletos commented on KAFKA-8604: - [~ymxz] So, in your case, setting the 

[jira] [Assigned] (KAFKA-8453) AdminClient describeTopic should handle partition level errors

[ https://issues.apache.org/jira/browse/KAFKA-8453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8453: -- Assignee: Lee Dongjin > AdminClient describeTopic should handle partition level errors >

[jira] [Commented] (KAFKA-8453) AdminClient describeTopic should handle partition level errors

[ https://issues.apache.org/jira/browse/KAFKA-8453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885289#comment-16885289 ] ASF GitHub Bot commented on KAFKA-8453: --- dongjinleekr commented on pull request #7089: KAFKA-8453:

[jira] [Commented] (KAFKA-8024) UtilsTest.testFormatBytes fails with german locale

[ https://issues.apache.org/jira/browse/KAFKA-8024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885284#comment-16885284 ] Patrik Kleindl commented on KAFKA-8024: --- [~sujayopensource] You need to ask for permissions on the

[jira] [Assigned] (KAFKA-8024) UtilsTest.testFormatBytes fails with german locale

[ https://issues.apache.org/jira/browse/KAFKA-8024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl reassigned KAFKA-8024: - Assignee: Patrik Kleindl > UtilsTest.testFormatBytes fails with german locale >

[jira] [Comment Edited] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

[ https://issues.apache.org/jira/browse/KAFKA-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885113#comment-16885113 ] Sam Weston edited comment on KAFKA-7931 at 7/15/19 11:40 AM: - Good news! I've

[jira] [Commented] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

[ https://issues.apache.org/jira/browse/KAFKA-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885113#comment-16885113 ] Sam Weston commented on KAFKA-7931: --- Good news! I've got to the bottom of it! The fix is to use a DNS

[jira] [Commented] (KAFKA-8658) A way to configure the jmx rmi port

[ https://issues.apache.org/jira/browse/KAFKA-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884970#comment-16884970 ] Agostino Sarubbo commented on KAFKA-8658: - Hello Richard,   thanks for the fast response. It

[jira] [Updated] (KAFKA-8664) non-JSON format messages when streaming data from Kafka to Mongo

[ https://issues.apache.org/jira/browse/KAFKA-8664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vu Le updated KAFKA-8664: - Description: Hi team, I can stream data from Kafka to MongoDB with JSON messages. I use MongoDB Kafka

[jira] [Updated] (KAFKA-8664) non-JSON format messages when streaming data from Kafka to Mongo

[ https://issues.apache.org/jira/browse/KAFKA-8664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vu Le updated KAFKA-8664: - Description: Hi team, I can stream data from Kafka to MongoDB with JSON messages. I use [MongoDB Kafka

[jira] [Created] (KAFKA-8664) non-JSON format messages when streaming data from Kafka to Mongo

Vu Le created KAFKA-8664: Summary: non-JSON format messages when streaming data from Kafka to Mongo Key: KAFKA-8664 URL: https://issues.apache.org/jira/browse/KAFKA-8664 Project: Kafka Issue Type: