Re: Possible bug in Authorize by ResourceTypeQue

I think we don't take implied access into account for authorizeByResourceType. The implied access is the other way round: ALLOW READ implies ALLOW DESCRIBE. So in your example, it doesn't make any difference to the result of authorizeByResourceType for READ whether implied access is taken into acco

[jira] [Created] (KAFKA-17477) Topic command integration test migrate to new test infra

TaiJuWu created KAFKA-17477: --- Summary: Topic command integration test migrate to new test infra Key: KAFKA-17477 URL: https://issues.apache.org/jira/browse/KAFKA-17477 Project: Kafka Issue Type: Te

Re: Implementing missing public method ConsumerRecords.nextOffsets

Hi Lucas, This sounds like an interesting approach and I wonder whether anyone will have the context about why this part of KIP-320 was not completed. There is one little detail that I can think of, which we can address later as the details are confirmed. KafkaShareConsumer also uses ConsumerRecor

[jira] [Created] (KAFKA-17480) New consumer commit all consumed should retrieve offsets in background thread

Lianet Magrans created KAFKA-17480: -- Summary: New consumer commit all consumed should retrieve offsets in background thread Key: KAFKA-17480 URL: https://issues.apache.org/jira/browse/KAFKA-17480 Pro

[jira] [Resolved] (KAFKA-17425) Improve coexistence of consumer groups and share groups

[ https://issues.apache.org/jira/browse/KAFKA-17425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-17425. -- Resolution: Fixed > Improve coexistence of consumer groups and share groups >

Re: [DISCUSS] GitHub CI

(I had to re-send this without most of the screenshots) Now that we've had both builds running for a little while, I thought it would be good to do a comparison. Since we don't have much signal from PRs yet, we'll just be looking at JDK17 trunk builds between August 15 and today. Jenkins: https:

[jira] [Created] (KAFKA-17482) Make share partition initialization async

Apoorv Mittal created KAFKA-17482: - Summary: Make share partition initialization async Key: KAFKA-17482 URL: https://issues.apache.org/jira/browse/KAFKA-17482 Project: Kafka Issue Type: Sub-t

[jira] [Created] (KAFKA-17484) Logs are deleted in Kafka 1.1.1 if logs.segment.bytes is changed

Georgios Kousouris created KAFKA-17484: -- Summary: Logs are deleted in Kafka 1.1.1 if logs.segment.bytes is changed Key: KAFKA-17484 URL: https://issues.apache.org/jira/browse/KAFKA-17484 Project:

[jira] [Created] (KAFKA-17485) Replace KafkaClientSupplier with KafkaClientInterceptor

Matthias J. Sax created KAFKA-17485: --- Summary: Replace KafkaClientSupplier with KafkaClientInterceptor Key: KAFKA-17485 URL: https://issues.apache.org/jira/browse/KAFKA-17485 Project: Kafka

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

I still need to catch up on the discussion in general. But as promised, I just started KIP-1088 about the `KafkaClientSupplier` question. Looking forward to your feedback on the new KIP. I hope we can get KIP-1088 done soon, to not block this KIP. -Matthias On 9/4/24 09:52, Lucas Brutschy w

Re: [DISCUSS] KIP-512: make Record Headers available in onAcknowledgement

Hi Rich, Thanks for the explanation. It’s true that it breaks use of a lambda as an implementation of Callback and I would say that it’s not acceptable to do this. I don’t think I’ve seen a use of this interface which didn’t use a lambda. I believe the main focus of this KIP was the improvement