[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803605#comment-16803605 ] John Roesler commented on KAFKA-7895: - Thanks for the extra details, [~AndrewRK], I'll try setting

[jira] [Commented] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

[ https://issues.apache.org/jira/browse/KAFKA-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803600#comment-16803600 ] Antony Stubbs commented on KAFKA-6042: -- [~ijuma] this is marked as both affects and fixed in 1.0.0 - 

[jira] [Commented] (KAFKA-8154) Buffer Overflow exceptions between brokers and with clients

[ https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803571#comment-16803571 ] Rajesh Nataraja commented on KAFKA-8154: [~rsivaram] I will get the outputs soon. But our

[jira] [Commented] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803512#comment-16803512 ] Guozhang Wang commented on KAFKA-8159: -- Thanks for reporting this. This is indeed an overlooked

[jira] [Commented] (KAFKA-8166) Kafka 2.2 Javadoc broken

[ https://issues.apache.org/jira/browse/KAFKA-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803499#comment-16803499 ] Guozhang Wang commented on KAFKA-8166: -- I've copied the javadocs of 22. It should be fixed now. >

[jira] [Resolved] (KAFKA-8166) Kafka 2.2 Javadoc broken

[ https://issues.apache.org/jira/browse/KAFKA-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8166. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.2.0 > Kafka 2.2

[jira] [Updated] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8159: --- Description: If a user creates a queryable state store using one of the signed

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

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

[jira] [Commented] (KAFKA-8168) Add a generated ApiMessageType class

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

[jira] [Commented] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803370#comment-16803370 ] John Roesler commented on KAFKA-8165: - Thanks for the report, [~xmar]. It sounds like the app ran

[jira] [Created] (KAFKA-8168) Add a generated ApiMessageType class

Colin P. McCabe created KAFKA-8168: -- Summary: Add a generated ApiMessageType class Key: KAFKA-8168 URL: https://issues.apache.org/jira/browse/KAFKA-8168 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8167) Document named stateful operators

[ https://issues.apache.org/jira/browse/KAFKA-8167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803329#comment-16803329 ] Kenny Williams commented on KAFKA-8167: --- I was looking for this documentation and could not find

[jira] [Commented] (KAFKA-1149) Please delete old releases from mirroring system

[ https://issues.apache.org/jira/browse/KAFKA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803328#comment-16803328 ] Guozhang Wang commented on KAFKA-1149: -- I've removed all old releases from

[jira] [Resolved] (KAFKA-1149) Please delete old releases from mirroring system

[ https://issues.apache.org/jira/browse/KAFKA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1149. -- Resolution: Fixed > Please delete old releases from mirroring system >

[jira] [Created] (KAFKA-8167) Document named stateful operators

John Roesler created KAFKA-8167: --- Summary: Document named stateful operators Key: KAFKA-8167 URL: https://issues.apache.org/jira/browse/KAFKA-8167 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-8166) Kafka 2.2 Javadoc broken

Sachin NS created KAFKA-8166: Summary: Kafka 2.2 Javadoc broken Key: KAFKA-8166 URL: https://issues.apache.org/jira/browse/KAFKA-8166 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803180#comment-16803180 ] Guozhang Wang commented on KAFKA-7190: -- Will file a KIP / PR for this discussion, but this ticket

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803153#comment-16803153 ] Guozhang Wang commented on KAFKA-7190: -- I agree. I think we shall at least increase `segment.ms` at

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection and store restoration

[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Environment: Kafka 2.1, Kafka Streams 2.1 Amazon Linux, on Docker based on wurstmeister/kafka image

[jira] [Updated] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8165: Summary: Streams task causes Out Of Memory after connection issues and store restoration (was: Streams

[jira] [Created] (KAFKA-8165) Streams task causes Out Of Memory after connection and store restoration

Di Campo created KAFKA-8165: --- Summary: Streams task causes Out Of Memory after connection and store restoration Key: KAFKA-8165 URL: https://issues.apache.org/jira/browse/KAFKA-8165 Project: Kafka

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803102#comment-16803102 ] John Roesler commented on KAFKA-6399: - Started KIP-442 for this change (

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803036#comment-16803036 ] ASF GitHub Bot commented on KAFKA-6399: --- vvcephei commented on pull request #6509: KAFKA-6399:

[jira] [Updated] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8159: - Description: If a user creates a queryable state store using one of the signed built-in serdes

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803008#comment-16803008 ] Guozhang Wang commented on KAFKA-6399: -- The ConsumerConfig's default is already set to 5min, so if

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802888#comment-16802888 ] Paul Whalen commented on KAFKA-7635: For what it's worth, my team is also running 2.0.0 and seems to

[jira] [Commented] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802836#comment-16802836 ] ASF GitHub Bot commented on KAFKA-8164: --- viktorsomogyi commented on pull request #6506: KAFKA-8164:

[jira] [Created] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

Viktor Somogyi-Vass created KAFKA-8164: -- Summary: Improve test passing rate by rerunning flaky tests Key: KAFKA-8164 URL: https://issues.apache.org/jira/browse/KAFKA-8164 Project: Kafka

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802771#comment-16802771 ] ASF GitHub Bot commented on KAFKA-8030: --- viktorsomogyi commented on pull request #6505: KAFKA-8030:

[jira] [Created] (KAFKA-8163) SetSchemaMetadata SMT does not apply to nested types

pierre bouvret created KAFKA-8163: - Summary: SetSchemaMetadata SMT does not apply to nested types Key: KAFKA-8163 URL: https://issues.apache.org/jira/browse/KAFKA-8163 Project: Kafka Issue

[jira] [Commented] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802712#comment-16802712 ] Vamsi commented on KAFKA-8161: -- As per the 

[jira] [Created] (KAFKA-8162) IBM JDK Class not found error when handling SASL authentication exception

Arkadiusz Firus created KAFKA-8162: -- Summary: IBM JDK Class not found error when handling SASL authentication exception Key: KAFKA-8162 URL: https://issues.apache.org/jira/browse/KAFKA-8162 Project:

[jira] [Commented] (KAFKA-8154) Buffer Overflow exceptions between brokers and with clients

[ https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802690#comment-16802690 ] Rajini Sivaram commented on KAFKA-8154: --- [~rnataraja] We don't seem to log SSL buffer sizes in

[jira] [Resolved] (KAFKA-8160) To add ACL with SSL authentication

[ https://issues.apache.org/jira/browse/KAFKA-8160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-8160. - Resolution: Information Provided Hi [~suseem...@gmail.com]   you can absolutely use SSL based

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: when executing config command,it suggest  that follower.replication.throttled.replicas  must

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: when executing config command,it suggest  that follower.replication.throttled.replicas  must

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: when executing config command,it suggest  that follower.replication.throttled.replicas  must

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: when executing config command,it suggest  that follower.replication.throttled.replicas  must

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1  --zookeeper 

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Description: bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1  --zookeeper 

[jira] [Updated] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haiping updated KAFKA-8161: --- Summary: Comma conflict when run script bin/kafka-configs.sh with config

[jira] [Created] (KAFKA-8161) config conflict when run script bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1 --zookeeper 10.39.0.54:2181/kafka102_test --add-config 'foll

Haiping created KAFKA-8161: -- Summary: config conflict when run script bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1 --zookeeper 10.39.0.54:2181/kafka102_test --add-config