[jira] [Created] (KAFKA-7388) An equal sign in a property value causes the broker to fail

Andre Araujo created KAFKA-7388: --- Summary: An equal sign in a property value causes the broker to fail Key: KAFKA-7388 URL: https://issues.apache.org/jira/browse/KAFKA-7388 Project: Kafka

[jira] [Commented] (KAFKA-7117) Allow AclCommand to use AdminClient API

[ https://issues.apache.org/jira/browse/KAFKA-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607821#comment-16607821 ] ASF GitHub Bot commented on KAFKA-7117: --- junrao closed pull request #5463: KAFKA-7117: Support

[jira] [Resolved] (KAFKA-7117) Allow AclCommand to use AdminClient API

[ https://issues.apache.org/jira/browse/KAFKA-7117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7117. Resolution: Fixed Fix Version/s: 2.1.0 Merged the PR to trunk. > Allow AclCommand to use

[jira] [Updated] (KAFKA-7386) Streams Scala wrapper should not cache serdes

[ https://issues.apache.org/jira/browse/KAFKA-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7386: --- Affects Version/s: (was: 2.1.0) > Streams Scala wrapper should not cache serdes >

[jira] [Commented] (KAFKA-7385) Log cleaner crashes when empty batches are retained with idempotent or transactional producers

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

[jira] [Updated] (KAFKA-7385) Log cleaner crashes when empty batches are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7385: Summary: Log cleaner crashes when empty batches are retained with idempotent or transactional

[jira] [Commented] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion

[ https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607679#comment-16607679 ] ASF GitHub Bot commented on KAFKA-6082: --- lindong28 closed pull request #5101: KAFKA-6082: Fence

[jira] [Resolved] (KAFKA-6082) consider fencing zookeeper updates with controller epoch zkVersion

[ https://issues.apache.org/jira/browse/KAFKA-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6082. - Resolution: Fixed > consider fencing zookeeper updates with controller epoch zkVersion >

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607647#comment-16607647 ] Matthias J. Sax commented on KAFKA-6699: Btw: I would highly recommend to read a book about Kafka

[jira] [Commented] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607642#comment-16607642 ] Matthias J. Sax commented on KAFKA-6699: I think I need to explain the configs again. Replication

[jira] [Commented] (KAFKA-6777) Wrong reaction on Out Of Memory situation

[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607574#comment-16607574 ] John Roesler commented on KAFKA-6777: - Hi [~habdank], When Java processes are under extreme memory

[jira] [Assigned] (KAFKA-7350) Improve or remove the PreferredReplicaImbalanceCount metric

[ https://issues.apache.org/jira/browse/KAFKA-7350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang reassigned KAFKA-7350: - Assignee: Ahmed Al-Mehdi (was: Lucas Wang) > Improve or remove the

[jira] [Updated] (KAFKA-7385) Log cleaner crashes when empty headers are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7385: Summary: Log cleaner crashes when empty headers are retained with idempotent or transactional

[jira] [Commented] (KAFKA-7385) Log compactor crashes when empty headers are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607475#comment-16607475 ] Apurva Mehta commented on KAFKA-7385: - This is interesting. I would have expected this test

[jira] [Comment Edited] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607436#comment-16607436 ] John Roesler edited comment on KAFKA-7214 at 9/7/18 6:00 PM: - Since you do

[jira] [Commented] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607436#comment-16607436 ] John Roesler commented on KAFKA-7214: - Since you do not have an OutOfMemoryException in your logs, I

[jira] [Resolved] (KAFKA-7387) Kafka distributed worker reads config from backup while launching connector

[ https://issues.apache.org/jira/browse/KAFKA-7387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] satyanarayan komandur resolved KAFKA-7387. -- Resolution: Not A Bug Issue is with the JDBC connector and not with the kafka

[jira] [Commented] (KAFKA-7239) Kafka Connect secret externalization not working

[ https://issues.apache.org/jira/browse/KAFKA-7239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607395#comment-16607395 ] satyanarayan komandur commented on KAFKA-7239: -- I confirmed the issue is with the JDBC

[jira] [Created] (KAFKA-7387) Kafka distributed worker reads config from backup while launching connector

satyanarayan komandur created KAFKA-7387: Summary: Kafka distributed worker reads config from backup while launching connector Key: KAFKA-7387 URL: https://issues.apache.org/jira/browse/KAFKA-7387

[jira] [Assigned] (KAFKA-7385) Log compactor crashes when empty headers are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah reassigned KAFKA-7385: --- Assignee: Dhruvil Shah > Log compactor crashes when empty headers are retained with

[jira] [Commented] (KAFKA-7386) Streams Scala wrapper should not cache serdes

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

[jira] [Updated] (KAFKA-7386) Streams Scala wrapper should not cache serdes

[ https://issues.apache.org/jira/browse/KAFKA-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7386: Fix Version/s: 2.1.0 2.0.1 > Streams Scala wrapper should not cache serdes >

[jira] [Updated] (KAFKA-7386) Streams Scala wrapper should not cache serdes

[ https://issues.apache.org/jira/browse/KAFKA-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7386: Component/s: streams > Streams Scala wrapper should not cache serdes >

[jira] [Updated] (KAFKA-7386) Streams Scala wrapper should not cache serdes

[ https://issues.apache.org/jira/browse/KAFKA-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7386: Affects Version/s: 2.1.0 2.0.0 > Streams Scala wrapper should not cache

[jira] [Commented] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607363#comment-16607363 ] Vasilis Tsamis commented on KAFKA-7384: --- We use the kafka-clients:1.1.0 producer.  > Compatibility

[jira] [Commented] (KAFKA-7351) Wrong logic in method ClusterConnectionStates.isDisconnected

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

[jira] [Created] (KAFKA-7386) Streams Scala wrapper should not cache serdes

John Roesler created KAFKA-7386: --- Summary: Streams Scala wrapper should not cache serdes Key: KAFKA-7386 URL: https://issues.apache.org/jira/browse/KAFKA-7386 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607291#comment-16607291 ] Ted Yu commented on KAFKA-6904: --- Haven't seen this failure lately. >

[jira] [Created] (KAFKA-7385) Log compactor crashes when empty headers are retained with idempotent / transaction producers

Dhruvil Shah created KAFKA-7385: --- Summary: Log compactor crashes when empty headers are retained with idempotent / transaction producers Key: KAFKA-7385 URL: https://issues.apache.org/jira/browse/KAFKA-7385

[jira] [Commented] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607260#comment-16607260 ] Ismael Juma commented on KAFKA-7384: Which client is being used to produce the messages? This is the

[jira] [Updated] (KAFKA-7385) Log compactor crashes when empty headers are retained with idempotent or transactional producers

[ https://issues.apache.org/jira/browse/KAFKA-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah updated KAFKA-7385: Summary: Log compactor crashes when empty headers are retained with idempotent or transactional

[jira] [Comment Edited] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607241#comment-16607241 ] Vasilis Tsamis edited comment on KAFKA-7384 at 9/7/18 3:21 PM: --- Our

[jira] [Commented] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607241#comment-16607241 ] Vasilis Tsamis commented on KAFKA-7384: --- Our producer uses the default compression type(which is

[jira] [Comment Edited] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607241#comment-16607241 ] Vasilis Tsamis edited comment on KAFKA-7384 at 9/7/18 3:20 PM: --- Our

[jira] [Commented] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607161#comment-16607161 ] Ismael Juma commented on KAFKA-7384: What is the configured compression type? > Compatibility issues

[jira] [Commented] (KAFKA-4544) Add system tests for delegation token based authentication

[ https://issues.apache.org/jira/browse/KAFKA-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607140#comment-16607140 ] Attila Sasvari commented on KAFKA-4544: --- Thanks [~omkreddy], I see your point. Today, it is not

[jira] [Comment Edited] (KAFKA-6690) Priorities for Source Topics

[ https://issues.apache.org/jira/browse/KAFKA-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605047#comment-16605047 ] Nick Afshartous edited comment on KAFKA-6690 at 9/7/18 1:22 PM:

[jira] [Commented] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607109#comment-16607109 ] Giannis Karagiannis commented on KAFKA-7384: Hello, please mind that this issue is not

[jira] [Updated] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasilis Tsanis updated KAFKA-7384: -- Description: Hello After upgrading the Kafka Brokers from 0.10.2.1 to 1.1.0, I am getting the

[jira] [Updated] (KAFKA-7384) Compatibility issues between Kafka Brokers 1.1.0 and older kafka clients

[ https://issues.apache.org/jira/browse/KAFKA-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasilis Tsanis updated KAFKA-7384: -- Description: Hello After upgrading the Kafka Brokers from 0.10.2.1 to 1.1.0, I am getting the

[jira] [Comment Edited] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606957#comment-16606957 ] Ashish Surana edited comment on KAFKA-7149 at 9/7/18 10:29 AM: --- [~guozhang] 

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606957#comment-16606957 ] Ashish Surana commented on KAFKA-7149: -- [~guozhang] As you suggested, below changes can reduce the

[jira] [Commented] (KAFKA-1880) Add support for checking binary/source compatibility

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

[jira] [Commented] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606846#comment-16606846 ] Seweryn Habdank-Wojewodzki commented on KAFKA-7214: --- Hi [~vvcephei], This is what I

[jira] [Commented] (KAFKA-7363) How num.stream.threads in streaming application influence memory consumption?

[ https://issues.apache.org/jira/browse/KAFKA-7363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606830#comment-16606830 ] Seweryn Habdank-Wojewodzki commented on KAFKA-7363: --- I would love to do that, but

[jira] [Comment Edited] (KAFKA-6777) Wrong reaction on Out Of Memory situation

[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606816#comment-16606816 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-6777 at 9/7/18 8:00 AM:

[jira] [Commented] (KAFKA-6777) Wrong reaction on Out Of Memory situation

[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606816#comment-16606816 ] Seweryn Habdank-Wojewodzki commented on KAFKA-6777: --- What means long pauses? I see

[jira] [Comment Edited] (KAFKA-6699) When one of two Kafka nodes are dead, streaming API cannot handle messaging

[ https://issues.apache.org/jira/browse/KAFKA-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606813#comment-16606813 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-6699 at 9/7/18 7:57 AM:

[jira] [Closed] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE

[ https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-6457. - > Error: NOT_LEADER_FOR_PARTITION leads to NPE >