Re: [kafka-clients] [VOTE] 2.7.2 RC0

Hi Mickael, As with 2.6.3 RC0, I have: * Verified checksums and signatures * Built jars and docs from the source jar * Run the unit and integration tests +1 non-binding Kind regards, Tom On Sun, Oct 24, 2021 at 3:05 PM Israel Ekpo wrote: > Mickael, > > Do we need to do another RC? Were ther

Re: [kafka-clients] [VOTE] 2.7.2 RC0

Hi Mickael, Thanks for the release. I did: 1. Verified checksums and signatures 2. Run quick start steps 3. Verified the CVE-2021-38153 is indeed fixed in kafka-2.7.2-src.tgz . +1 (non-binding) Thank you. Luke On Tue, Oct 26

Re: [VOTE] KIP-782: Expandable batch size in producer

Thank you, Artem! @devs, welcome to vote for this KIP. Key proposal: 1. allocate multiple smaller initial batch size buffer in producer, and list them together when expansion for better memory usage 2. add a max batch size config in producer, so when producer rate is suddenly high, we can still ha

[jira] [Created] (KAFKA-13404) Kafka sink connectors do not commit offset correctly if messages are produced in transaction

Yu-Jhe Li created KAFKA-13404: - Summary: Kafka sink connectors do not commit offset correctly if messages are produced in transaction Key: KAFKA-13404 URL: https://issues.apache.org/jira/browse/KAFKA-13404

Re: [DISCUSS] KIP-787 - MM2 Interface to manage Kafka resources

Hey Ryanne, Thanks fo the quick feedback. Using the Admin interface would make everything easier, as MM2 will need only to configure the classpath for the new implementation and use it instead of AdminClient. However, I have two concerns 1. The Admin interface is enormous, and the MM2 users will ne

Re: [kafka-clients] [VOTE] 2.6.3 RC0

Thanks for running the release Mickael. I did the following: 1. Validated signatures 2. Validated checksums 3. Built from source 4. Ran all the unit tests 5. Spot checked the Javadocs +1(binding) -Bill On Mon, Oct 25, 2021 at 8:24 PM Israel Ekpo wrote: > Hello Friends > > We

Re: [DISCUSS] KIP-787 - MM2 Interface to manage Kafka resources

I like the idea of failing-fast whenever a custom impl is provided, but I suppose that that could be done for Admin as well. I agree your proposal is more ergonomic, but maybe it's okay to have a little friction in such fringe use-cases. Ryanne On Tue, Oct 26, 2021, 6:23 AM Omnia Ibrahim wrote:

[jira] [Created] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

Daniel O'Halloran created KAFKA-13405: - Summary: Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster Key: KAFKA-13405 URL: https://issues.apache.org/jira/browse/KAFKA-13405

[DISCUSS] KIP-788: Allow configuring num.network.threads per listener

Hi all, I wrote a KIP to allow setting the number of network threads per listener: https://cwiki.apache.org/confluence/display/KAFKA/KIP-788%3A+Allow+configuring+num.network.threads+per+listener Please let me know if you have any feedback. Thanks

Re: [kafka-clients] [VOTE] 2.7.2 RC0

Hi Mickael, Thanks for running the release. Steps taken 1. Validated checksums 2. Validated signatures 3. Built from source 4. Ran all the unit tests 5. Spot checked various JavaDocs +1(binding) On Tue, Oct 26, 2021 at 4:43 AM Luke Chen wrote: > Hi Mickael, > > Thanks for the

Re: [DISCUSS] KIP-788: Allow configuring num.network.threads per listener

Neat! Makes sense to me. Ryanne On Tue, Oct 26, 2021, 11:02 AM Mickael Maison wrote: > Hi all, > > I wrote a KIP to allow setting the number of network threads per listener: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-788%3A+Allow+configuring+num.network.threads+per+listener > > P

Re: [DISCUSS] KIP-788: Allow configuring num.network.threads per listener

Mickael, It will great to specify if the listener name is case sensitive (ie do you need to use upper case in the config) Your examples should reference actual listener names and the case (upper or lower) to make it clear for the users Nevertheless, the KIP is solid and will help configure and

Re: [kafka-clients] [VOTE] 2.7.2 RC0

Thanks Bill. That is greatly appreciated :) We need more PMC members with binding votes to participate. You can do it! On Tue, Oct 26, 2021 at 1:25 PM Bill Bejeck wrote: > Hi Mickael, > > Thanks for running the release. > > Steps taken > >1. Validated checksums >2. Validated signatures

[jira] [Resolved] (KAFKA-10800) Validate the snapshot id when the state machine creates a snapshot

[ https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10800. - Resolution: Fixed > Validate the snapshot id when the state machine creates a snapshot >

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

See Changes: -- [...truncated 425372 lines...] [2021-10-26T22:32:17.980Z] [2021-10-26T22:32:17.980Z] LogCleanerParameterizedIntegrationTest > testCleaningNestedMessagesWit

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

See Changes: -- [...truncated 493469 lines...] [2021-10-27T00:40:53.863Z] at java.base/sun.nio.ch.Net.bind0(Native Method) [2021-10-27T00:40:53.863Z]