[jira] [Resolved] (KAFKA-7137) ability to trigger compaction for tombstoning and GDPR

[ https://issues.apache.org/jira/browse/KAFKA-7137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brett Rann resolved KAFKA-7137. --- Resolution: Duplicate > ability to trigger compaction for tombstoning and GDPR >

[jira] [Commented] (KAFKA-7137) ability to trigger compaction for tombstoning and GDPR

[ https://issues.apache.org/jira/browse/KAFKA-7137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605262#comment-16605262 ] Brett Rann commented on KAFKA-7137: --- there was a race condition of people working on this idea, and

[jira] [Resolved] (KAFKA-7365) max.poll.records setting in Kafka Consumer is not working

[ https://issues.apache.org/jira/browse/KAFKA-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7365. Resolution: Invalid > max.poll.records setting in Kafka Consumer is not working >

[jira] [Commented] (KAFKA-7365) max.poll.records setting in Kafka Consumer is not working

[ https://issues.apache.org/jira/browse/KAFKA-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605237#comment-16605237 ] Matthias J. Sax commented on KAFKA-7365: Thanks for verifying that changing the configs solves

[jira] [Commented] (KAFKA-7353) Connect logs 'this' for anonymous inner classes

[ https://issues.apache.org/jira/browse/KAFKA-7353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605207#comment-16605207 ] ASF GitHub Bot commented on KAFKA-7353: --- ewencp closed pull request #5583: KAFKA-7353; Connect logs

[jira] [Resolved] (KAFKA-7353) Connect logs 'this' for anonymous inner classes

[ https://issues.apache.org/jira/browse/KAFKA-7353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7353. -- Resolution: Fixed Fix Version/s: 2.1.0 2.0.1

[jira] [Created] (KAFKA-7381) Parameterize connector rebalancing behavior

Chen He created KAFKA-7381: -- Summary: Parameterize connector rebalancing behavior Key: KAFKA-7381 URL: https://issues.apache.org/jira/browse/KAFKA-7381 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605116#comment-16605116 ] Matthias J. Sax commented on KAFKA-7318: {quote}Thanks for the answer, but I don't understand why

[jira] [Commented] (KAFKA-7380) Global thread restore blocks KafkaStreams#start()

[ https://issues.apache.org/jira/browse/KAFKA-7380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605089#comment-16605089 ] Guozhang Wang commented on KAFKA-7380: -- Some initial thoughts about how to do it: 1. Whenever a

[jira] [Created] (KAFKA-7380) Global thread restore blocks KafkaStreams#start()

Matthias J. Sax created KAFKA-7380: -- Summary: Global thread restore blocks KafkaStreams#start() Key: KAFKA-7380 URL: https://issues.apache.org/jira/browse/KAFKA-7380 Project: Kafka Issue

[jira] [Updated] (KAFKA-7379) send.buffer.bytes should be allowed to set -1 in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7379: --- Labels: beginner easyfix newbie (was: ) > send.buffer.bytes should be allowed to set -1 in

[jira] [Created] (KAFKA-7379) send.buffer.bytes should be allowed to set -1 in KafkaStreams

Badai Aqrandista created KAFKA-7379: --- Summary: send.buffer.bytes should be allowed to set -1 in KafkaStreams Key: KAFKA-7379 URL: https://issues.apache.org/jira/browse/KAFKA-7379 Project: Kafka

[jira] [Commented] (KAFKA-7365) max.poll.records setting in Kafka Consumer is not working

[ https://issues.apache.org/jira/browse/KAFKA-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605019#comment-16605019 ] Matthias J. Sax commented on KAFKA-7365: So how long do you expect that it take to process the

[jira] [Updated] (KAFKA-7378) Consumer poll hangs if broker shutdown while consumer attempting to connect.

[ https://issues.apache.org/jira/browse/KAFKA-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Calcote updated KAFKA-7378: Description: I have an integration test that creates a Spring context, starting up the

[jira] [Created] (KAFKA-7378) Consumer poll hangs if broker shutdown while consumer attempting to connect.

John Calcote created KAFKA-7378: --- Summary: Consumer poll hangs if broker shutdown while consumer attempting to connect. Key: KAFKA-7378 URL: https://issues.apache.org/jira/browse/KAFKA-7378 Project:

[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=16604711#comment-16604711 ] Manikumar commented on KAFKA-4544: -- [~asasvari] Thanks for taking this. I was planning to write a

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604639#comment-16604639 ] Jason Gustafson commented on KAFKA-7044: Thanks [~ejpearson] for the investigation. I think the

[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=16604530#comment-16604530 ] Attila Sasvari commented on KAFKA-4544: --- [~omkreddy] thanks a lot! - I started to work on this

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604519#comment-16604519 ] Tom Scott commented on KAFKA-7044: -- I hit this with Confluent Platform 4.1.2, using the

[jira] [Commented] (KAFKA-7367) Verify that Streams never creates RocksDB stores unless they are needed

[ https://issues.apache.org/jira/browse/KAFKA-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604478#comment-16604478 ] John Roesler commented on KAFKA-7367: - Sorry, I should have said "someone mentioned it to me in

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604427#comment-16604427 ] Kobi Hikri commented on KAFKA-1194: --- BTW, Steps to reproduce are as follows: 1. Set in

[jira] [Updated] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kobi Hikri updated KAFKA-1194: -- Attachment: kafka-bombarder.7z > The kafka broker cannot delete the old log files after the configured

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604413#comment-16604413 ] Kobi Hikri commented on KAFKA-1194: --- Sure Stephane. Will update shortly. > The kafka broker cannot

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604408#comment-16604408 ] Stephane Maarek commented on KAFKA-1194: hi [~Kobi Hikri], can you please test one more time

[jira] [Commented] (KAFKA-7376) After Kafka upgrade to v2.0.0 , Controller unable to communicate with brokers on SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604342#comment-16604342 ] Sridhar commented on KAFKA-7376: Hi [~ijuma], I am using single certificate for all three broker nodes

[jira] [Assigned] (KAFKA-6708) Review Exception messages with regards to Serde Useage

[ https://issues.apache.org/jira/browse/KAFKA-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-6708: -- Assignee: Mariam John > Review Exception messages with regards to Serde Useage >

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2939: -- Assignee: Mariam John > Make AbstractConfig.logUnused() tunable for clients >

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4650: -- Assignee: Mariam John > Improve test coverage org.apache.kafka.streams.kstream.internals >

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16604253#comment-16604253 ] Kobi Hikri commented on KAFKA-1194: --- Hi all, Just built and tested @simplestephs proposed solution on

[jira] [Assigned] (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:all-tabpanel ] Attila Sasvari reassigned KAFKA-4544: - Assignee: Attila Sasvari (was: Manikumar) > Add system tests for delegation token