Re: [VOTE] KIP-815: Replace KafkaConsumer with AdminClient in GetOffsetShell

Hey, Thanks for updating the KIP. I think that there are a few more configs which could be used. e.g. all the network related configs - they are in both consumer and admin configurations as well. Is `session.timeout.ms` relevant in our context? It does not seem to be used when querying offsets. R

[jira] [Created] (KAFKA-13637) User default.api.timeout.ms config as default timeout for KafkaConsumer.endOffsets

dengziming created KAFKA-13637: -- Summary: User default.api.timeout.ms config as default timeout for KafkaConsumer.endOffsets Key: KAFKA-13637 URL: https://issues.apache.org/jira/browse/KAFKA-13637 Projec

Re: [VOTE] KIP-815: Replace KafkaConsumer with AdminClient in GetOffsetShell

Hey David, I rechecked the ConsumerConfig and split the Compatibility section into 2 sub-sections regarding AdminClientConfig and ConsumerConfig, I also find a small bug that we use different timeout in `KafkaConsumer.beginningOffsets` and `KafkaConsumer.endOffsets`, I will fix this. Please he

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

See

[jira] [Reopened] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13152: - The PR broke backward compatibility. Needed to revert the commit. Sorry about that. Lets d

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

See

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

See

[jira] [Created] (KAFKA-13636) Committed offsets could be deleted during a rebalance if a group did not commit for a while

Damien Gasparina created KAFKA-13636: Summary: Committed offsets could be deleted during a rebalance if a group did not commit for a while Key: KAFKA-13636 URL: https://issues.apache.org/jira/browse/KAFKA-1363

[jira] [Resolved] (KAFKA-13527) Add top-level error code field to DescribeLogDirsResponse

[ https://issues.apache.org/jira/browse/KAFKA-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-13527. Fix Version/s: 3.2.0 Resolution: Fixed > Add top-level error code field to Describe

[jira] [Resolved] (KAFKA-13595) Allow producing records with null values in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-13595. Fix Version/s: 3.2.0 Resolution: Fixed > Allow producing records with null values i

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

Thanks, David. +1 (non-binding) From: show...@gmail.com At: 01/31/22 22:13:57 UTC-5:00To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-814: Static membership protocol should let the leader skip assignment Hi David, Thanks for the KIP. I'm +1(non-binding) Thanks. Luke Jason Gustafson 於 202

Re: [VOTE] KIP-801 new authorizer for kip-500 kraft mode

+1 Thanks! On Mon, Jan 31, 2022 at 6:20 PM Colin McCabe wrote: > Hi all, > > It looks like people using gmail are seeing the previous vote thread as > merged with the discuss thread, so let me create a new thread in order to > avoid confusion. Usually using a very different thread title works we

Re: Understanding the SASL/PLAIN mechanism

Hello all, Anyone involved in Kafka's SASL support got time to help with this? Thankfully KIP-255 ( https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75968876) helped shed light on things but from the SASL/OAUTHBEARER perspective instead of SASL/PLAIN, but if anyone has time to h

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

See

[jira] [Created] (KAFKA-13635) Make Consumer Group Protocol resilient to disk issues with __consumer_offsets

Akhilesh Dubey created KAFKA-13635: -- Summary: Make Consumer Group Protocol resilient to disk issues with __consumer_offsets Key: KAFKA-13635 URL: https://issues.apache.org/jira/browse/KAFKA-13635 Pr

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

See

Re: [VOTE] KIP-815: Replace KafkaConsumer with AdminClient in GetOffsetShell

Thanks for the updated KIP. Regarding the compatibility section, I think that it would be great if we could really stress that the configurations that could reasonably be used to configure the tool are actually all supported by the admin client. Regarding the retry mechanism, the consumer will ret

Re: [DISCUSS] KIP-795: Add public APIs for AbstractCoordinator

Hi Hector, Thanks for the KIP. I finally had a bit of time to read it. I understand that a few services have been leveraging Kafka's Group Membership Protocol to do leader election and/or service discovery. However, I am not entirely convinced that Kafka should be used in that way because special

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

Hi Matthias, Good point! I didn't notice that. Yes, I agree it's not good to let store depends on kstream package. I'll remove the stores API change later. (after Chinese new year :) ) Thanks for your good suggestion! Luke Matthias J. Sax 於 2022年2月1日 週二 下午3:10 寫道： > Thanks for updating the K

[VOTE] KIP-815: Support max-timestamp in GetOffsetShell

Thank you David, I retitled this KIP to be more accurate and supplemented the Compatibility and Rejected Alternatives sections, please help to review this again. Best, Ziming Deng > On Jan 31, 2022, at 6:12 PM, David Jacot wrote: > > Hey, > > Thanks for the KIP. I have a few comments: > > 1.