Re: [VOTE] KIP-591: Add Kafka Streams config to set default state store

Thanks, There is already `Stores.persistentSessionStore` and `Stores.inMemorySessionStore`. From a DSL code POV, I don't see large benefits to add a new one, but it also does not hurt. Do you propose to add the third one only, or to also deprecate the existing ones? In general, we should avo

Re: [VOTE] KIP-591: Add Kafka Streams config to set default state store

Thanks Matthias! I agree we could deprecate the existing ones, and add the one with storeType parameter. That is: @deprecated Stores#persistentSessionStore(...) @deprecated Stores#inMemorySessionStore(...) @new added with an additional storeType parameter (IN_MEMORY or ROCKS_DB) Stores#sessionSto

Jenkins build is unstable: Kafka » Kafka Branch Builder » 2.8 #96

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #170

See

Re: [VOTE] KIP-799: Align behaviour for producer callbacks with documented behaviour

Hi all, Bumping this voting thread, as it still needs one more binding vote to pass. Regards, Séamus. On Mon, 6 Dec 2021 at 12:04, Mickael Maison wrote: > Thanks for the KIP! > +1 (binding) > > On Sat, Dec 4, 2021 at 3:49 AM Luke Chen wrote: > > > > Hi Séamus, > > > > Thanks for the update. >

Re: [VOTE] KIP-784: Add top-level error code field to DescribeLogDirsResponse

Hi, Since it's a pretty minor KIP, I'll do +1 (binding) myself and close the vote. The vote has passed with: - 3 +1 (binding) votes from Tom, David and Mickael - 1 +1 (non binding) vote from Luke Thanks, Mickael On Thu, Dec 16, 2021 at 10:07 AM David Jacot wrote: > > +1 (binding). Thanks for

[jira] [Created] (KAFKA-13616) Log4j 1.X CVE-2022-23302/5/7 vulnerabilities

Dominique Mongelli created KAFKA-13616: -- Summary: Log4j 1.X CVE-2022-23302/5/7 vulnerabilities Key: KAFKA-13616 URL: https://issues.apache.org/jira/browse/KAFKA-13616 Project: Kafka Issu

[jira] [Created] (KAFKA-13617) Enhance delete-expired-group-metadata logging

Nicolas Guyomar created KAFKA-13617: --- Summary: Enhance delete-expired-group-metadata logging Key: KAFKA-13617 URL: https://issues.apache.org/jira/browse/KAFKA-13617 Project: Kafka Issue Typ

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #629

See Changes: -- [...truncated 509369 lines...] [2022-01-25T15:30:20.786Z] > Task :clients:publishMavenJavaPublicationToMavenLocal [2022-01-25T15:30:20.786Z] > Task :clients

[DISCUSS] KIP-816: Topology changes without local state reset

Hi everyone, I'd like to start a discussion on Kafka Streams KIP-816 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-816%3A+Topology+changes+without+local+state+reset ) This KIP outlines 3 possible solutions to the problem, and I plan to whittle this down to a definitive solution based on

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #630

See

Re: [DISCUSS] KIP-704: Send a hint to broker if it is an unclean leader

On Fri, Jan 21, 2022, at 11:07, José Armando García Sancio wrote: > Hi all, > > The following suggestions are not strictly required to implement this > KIP but what do we think about: > > 1. Changing the name of the AlterIsr RPC to AlterPartition RPC. > > 2. Change the name of the field "CurrentIsr

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

See

Re: [VOTE] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

Hi Colin, Thanks for the writeup. I had one question about bootstrapping. For the brokers, I understand that listener startup is delayed until the Authorizer is ready. However, I was not very clear how this would work for the controller listeners. We may need them to startup before the metadata lo

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #632

See Changes: -- [...truncated 509358 lines...] [2022-01-25T22:21:23.687Z] > Task :clients:generatePomFileForMavenJavaPublication [2022-01-25T22:21:23.687Z] [2022-01-25T22:

Re: [VOTE] KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata

How about this: We create a configuration key called early.start.listeners which contains a list of listener names. If this is not specified, its value defaults to just the controller listeners. Optionally, other listeners can be added too. If super.users contains any user names, early start li

Re: [DISCUSS] KIP-814: Static membership protocol should let the leader skip assignment

Hey David, Yeah, there might not be a simple option to address the scenario I described. Other than a broker-side solution, another way we could fix it is by adding additional metadata to the assignment. I do agree that it might not be worth the additional complexity. At least we should probably

[jira] [Resolved] (KAFKA-13585) Fix `kafka.server.ReplicaManagerTest.testReplicaAlterLogDirsWithAndWithoutIds` flaky test

[ https://issues.apache.org/jira/browse/KAFKA-13585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13585. - Fix Version/s: 3.2.0 3.1.1 Reviewer: Jason Gustafson Resolutio