[DISCUSS] KIP-828: Add the corresponding validator to the configuration where the validator is missing

nding+validator+to+the+configuration+where+the+validator+is+missing Please take a look and let me know if you have any feedback. Thanks. Riven Sun

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

n Sat, Feb 12, 2022 at 5:32 PM Riven Sun wrote: > >> Sorry, I sent this email via GMail. Refer to the contents of other >> people's DISSCUSS emails. Mistakenly introduced someone else's KIP. >> >> The KIP related to this DISCUSS is >> https://cwiki.apache.

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

> > > Sorry, I sent this email via GMail. Refer to the contents of other > people's DISSCUSS emails. Mistakenly introduced someone else's KIP. > > The KIP related to this DISCUSS is > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=199534763 > > Thank you for your kindness > RivenS

[DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

Hi team, I opened a KIP to add the option to make the semantics of the KafkaConsuemr#Pause method consistent under different RebalanceProtocols: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=199534763

[DISCUSS] KafkaClient parameter optimization: java.security.auth.login.config

Hi Kafka devs, I found that when KafkaClient establishes a sasl connection, if `java.security.auth.login.config` is used and multiple LoginModules are configured in JaasConfigFile (regardless of whether these LoginModules are of the same type), KafkaClient will get the wrong username&password from

[DISCUSS] Broker parameter optimization: security.inter.broker.protocol

Hi Kafka devs, The default behavior of security.inter.broker.protocol is: "InterBrokerListenerName=ListenerName.forSecurityProtocol(securityProtocol)" . We are not aware of this behavior from the security.inter.broker.protocol comment on the latest official website of Kafka. After using this config

[DISCUSS] KafkaConsumer pause(Collection partitions)

Hi Kafka devs, For the existing KafkaConsumer pause method, I think it needs to be improved. At the same time, KafkaConsumer should be able to support the pause method that is not affected by groupRebalance. I give some suggestions on this, I hope you can actively participate in the discussion. And

Wiki Permissions

Hello, team I'd like to be added to the contributors list, so I can submit a KIP. My Jira ID is: RivenSun Wiki ID: rivensun Best Regards --- RivenSun