Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2916

See

[jira] [Created] (KAFKA-16793) Heartbeat API for upgrading ConsumerGroup

Dongnuo Lyu created KAFKA-16793: --- Summary: Heartbeat API for upgrading ConsumerGroup Key: KAFKA-16793 URL: https://issues.apache.org/jira/browse/KAFKA-16793 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-15723) KRaft support in ListOffsetsRequestTest

[ https://issues.apache.org/jira/browse/KAFKA-15723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-15723. Fix Version/s: 3.8.0 Resolution: Fixed > KRaft support in ListOffsetsRequestTest >

[jira] [Resolved] (KAFKA-16544) DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE

[ https://issues.apache.org/jira/browse/KAFKA-16544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16544. Fix Version/s: 3.8 Resolution: Fixed > DescribeTopicsResult#allTopicIds and Describ

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2914

See

[jira] [Created] (KAFKA-16792) Enable related unit tests that fail only for new consumer with to poll(0)

Lianet Magrans created KAFKA-16792: -- Summary: Enable related unit tests that fail only for new consumer with to poll(0) Key: KAFKA-16792 URL: https://issues.apache.org/jira/browse/KAFKA-16792 Project

[jira] [Created] (KAFKA-16791) Add thread detection to ClusterTestExtensions

Chia-Ping Tsai created KAFKA-16791: -- Summary: Add thread detection to ClusterTestExtensions Key: KAFKA-16791 URL: https://issues.apache.org/jira/browse/KAFKA-16791 Project: Kafka Issue Type:

Re: [VOTE] KIP-1028: Docker Official Image for Apache Kafka

Hi everyone! Thanks for participating in the discussion and voting! KIP-1028 has been accepted with the following +1 votes: - Chris Egerton (binding) - Manikumar (binding) - Justine Olshan (binding) - Hector Geraldino (non-binding) The target release for this KIP is 3.8.0 Thanks and regards, Ve

[jira] [Created] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

Christo Lolov created KAFKA-16790: - Summary: Calls to RemoteLogManager are made before it is configured Key: KAFKA-16790 URL: https://issues.apache.org/jira/browse/KAFKA-16790 Project: Kafka

[jira] [Resolved] (KAFKA-16763) Upgrade to scala 2.12.19 and scala 2.13.14

[ https://issues.apache.org/jira/browse/KAFKA-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16763. Fix Version/s: 3.8.0 Resolution: Fixed > Upgrade to scala 2.12.19 and scala 2.13.14

Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation

Respectfully, I don't agree. Why should we persist useless information for clients that are long gone and will never use it? This is why I'm suggesting we do something smarter when it comes to storing data and only store data we actually need and have a use for. This is why I suggest the heartbeat

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2913

See

[jira] [Resolved] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup

[ https://issues.apache.org/jira/browse/KAFKA-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16762. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed > SyncGroup API for

Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls

> > This has implications for execution complexity: If we can't compute > whether two patterns overlap, then we need to run both of them on each > piece of input to test if they both match. Under the current > LITERAL/PREFIX system, we can optimize execution with a trie, but that > option wouldn't

[jira] [Created] (KAFKA-16789) Thread leak detection checks for incorrect QuorumController thread name

Gaurav Narula created KAFKA-16789: - Summary: Thread leak detection checks for incorrect QuorumController thread name Key: KAFKA-16789 URL: https://issues.apache.org/jira/browse/KAFKA-16789 Project: Ka

Re: [DISCUSS] KIP-1042 support for wildcard when creating new acls

Updated KIP with the provided suggestions from Greg and Claude. We shall optimize matching acls with Trie based solutions for PREFIXED and LITERAL acls. Basically we define trie structures, populate trie and retrieve acls which seems very efficient. This way, we aim to reduce the time to authorize

[jira] [Created] (KAFKA-16788) Resource leakage due to absence of close() call on connector start failure

Ashok created KAFKA-16788: - Summary: Resource leakage due to absence of close() call on connector start failure Key: KAFKA-16788 URL: https://issues.apache.org/jira/browse/KAFKA-16788 Project: Kafka

Re: [DISCUSS] KIP-1035: StateStore managed changelog offsets

Hi everyone, As discussed on the Zoom call, we're going to handle rebalance meta-data by: - On start-up, Streams will open each store and read its changelog offsets into an in-memory cache. This cache will be shared among all StreamThreads. - On rebalance, the cache will be consulted for Task off

Re: please let me subscribe

Hi Greg, Thank you for your help! I've used the correct subscription API now (consumer.subscribe(Arrays.asList("dev-subscr...@kafka.apache.org"));). Apologies for the spam.

Re: [DISCUSS] KIP-1044: A proposal to change idempotent producer -- server implementation

I think that the point here is that the design that assumes that you can keep all the PIDs in memory for all server configurations and all usages and all client implementations is fraught with danger. Yes, there are solutions already in place (KIP-854) that attempt to address this problem, and oth