[jira] [Created] (KAFKA-13886) improve the performance org.apache.kafka.common.utils.Utils#isEqualConstantTime

lqjacklee created KAFKA-13886: - Summary: improve the performance org.apache.kafka.common.utils.Utils#isEqualConstantTime Key: KAFKA-13886 URL: https://issues.apache.org/jira/browse/KAFKA-13886 Project

[Discuss] KIP-832: Allow creating a producer/consumer using a producer/consumer config

Hi Bruno and frosiere, Thanks for raising this KIP, this would be a useful improvement! I advise just expose Map and Properties to the user. so that the parameters will be consistent with old one. the Advise like : 1, consumer api: public KafkaConsumer(Map configs, Des

Re: Possible Bug: kafka-reassign-partitions causing the data retention time to be reset

The resource (https://mike.seid.io/blog/decommissiong-a-kafka-node.html) may help you. I have created (https://issues.apache.org/jira/browse/KAFKA-13860) to replay the case . On Thu, Apr 28, 2022 at 10:33 PM Fares Oueslati wrote: > Hello, > > I'm not sure how to report this properly but I didn't

[jira] [Created] (KAFKA-13860) add Decommissioning feature to kafka-reassign-partitions.sh

lqjacklee created KAFKA-13860: - Summary: add Decommissioning feature to kafka-reassign-partitions.sh Key: KAFKA-13860 URL: https://issues.apache.org/jira/browse/KAFKA-13860 Project: Kafka

[jira] [Created] (KAFKA-10762) alter the backoff in `KafkaConsumer.pollForFetches`

lqjacklee created KAFKA-10762: - Summary: alter the backoff in `KafkaConsumer.pollForFetches` Key: KAFKA-10762 URL: https://issues.apache.org/jira/browse/KAFKA-10762 Project: Kafka Issue Type

Re: Reg:API for adding new CA public ke to kafka listener truststore

I think we should provide the command shell tool for customers to upgrade the configuration to support it . could help create the jira ? thanks. On Mon, Nov 23, 2020 at 11:15 PM Bharath Ambati wrote: > Hi, > Is there any support in kafka admin api for subjected requirement? > We have u

Re: New Contributor

thanks a lot . On Tue, Nov 17, 2020 at 6:33 PM Mickael Maison wrote: > Hi, > > I've added you to the contributors list. > Thanks > > On Tue, Nov 17, 2020 at 2:52 AM lqjacklee wrote: > > > > Dear team, > > > > could you please add me as a contrib

New Contributor

Dear team, could you please add me as a contributor for Apache Kafka? github: dorwi (https://github.com/lqjack/kafka) jira: username : Jack-Lee, full name : lqjacklee

[jira] [Created] (KAFKA-10208) org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.OffsetFetchResponseHandler return null when Broker unexpectedly doesn't support requireStable flag on ver

lqjacklee created KAFKA-10208: - Summary: org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.OffsetFetchResponseHandler return null when Broker unexpectedly doesn't support requireStable flag on version while not any inform

Re: KAFKA-10145

> > Paul > > > On Jun 10, 2020, at 10:13 PM, lqjacklee wrote: > > > > Dear team, > > > > I have created the JRIA > https://issues.apache.org/jira/browse/KAFKA-10145. > > I want to enhance the join feature to support the multiple join/aggregate > >

KAFKA-10145

Dear team, I have created the JRIA https://issues.apache.org/jira/browse/KAFKA-10145. I want to enhance the join feature to support the multiple join/aggregate for stream. If anyone is interested or have questions can idea, please let me know, thanks.

[jira] [Created] (KAFKA-10145) Enhance to support the multiple join operation

lqjacklee created KAFKA-10145: - Summary: Enhance to support the multiple join operation Key: KAFKA-10145 URL: https://issues.apache.org/jira/browse/KAFKA-10145 Project: Kafka Issue Type