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

Hi Omnia, 1. I might be missing something, but can you give a concrete Java example of how the proposed ForwardingAdmin class is more convenient than subclassing the KafkaAdminClient class? AFAICT the two would be virtually identical. I might be misunderstanding exactly how that class will be used

Re: [DISCUSS] KIP-821: Connect Transforms support for nested structures

Hi Jorge, Thanks! Sorry for the delay; here are my thoughts: 1. Under the "Accessing multiple values by deep-scan" header it's stated that "If deep-scan is used, it must have only one field after the asterisk level.". However, in example 3 for the Cast SMT and other examples for other SMTs, the s

Re: [DISCUSS] KIP-842: Add richer group offset reset mechanisms

I think making it a separate enum config is ok, it is similar to a boolean config but provide more choices, so the config name should be offset.reset.strategy.offset-out-of-range? - - Best, Ziming > On May 30, 2022, at 9:48 PM, hudeqi <16120...@bjtu.edu.cn> wrote: > > Hi, Ziming. > I thought

[jira] [Resolved] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13592. - Resolution: Fixed > Fix flaky test > ControllerIntegrationTest.testTopicIdUpgradeAfterR

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

See Changes: -- [...truncated 6184 lines...] [2022-06-06T18:30:48.114Z] > Task :jmh-benchmarks:classes [2022-06-06T18:30:48.114Z] > Task :jmh-benchmarks:compileTestJava NO-S

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

See Changes: -- [...truncated 6158 lines...] [Pipeline] } [Pipeline] // timestamps [Pipeline] } [Pipeline] // timeout [Pipeline] } [Pipeline] // stage [Pipeline] } Failed in

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

Hi Chris, Thanks for having the time to look into this. 1. Is the introduction of the new "ForwardingAdmin" class necessary, or can > the same behavior can be achieved by subclassing the existing > KafkaAdminClient class? forwarding decorators give more flexibility than the inheritance, in this c

[jira] [Created] (KAFKA-13961) GKE kafka-consumer-groups returns incorrect hosts

Mikhail Filatov created KAFKA-13961: --- Summary: GKE kafka-consumer-groups returns incorrect hosts Key: KAFKA-13961 URL: https://issues.apache.org/jira/browse/KAFKA-13961 Project: Kafka Issue