Re: After upgrade to 2.13 2.8.1 getting message in log

2022-02-25 Thread Luke Chen
Hi Jim, Thanks for reporting the issue. Could you file a jire bug here ? > I have found several blogs/user group references to the message but none have successfully stop the message Could you share these ref

After upgrade to 2.13 2.8.1 getting message in log

2022-02-25 Thread Jim Langston
Hi all , after upgrading to 2.8.1 and restarting the brokers, one of the brokers is continually logging messages similar to this Feb 25 23:58:17 bigdata-worker2.dc.res0.local WARN: (Logging.scala:70) [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Reset fetch offset for partition __consu

Re: KAFKA- UNDER_REPLICATED_PARTIONS - AUTOMATE

2022-02-25 Thread Malcolm McFarland
Maybe this could help? https://github.com/dimas/kafka-reassign-tool Cheers, Malcolm McFarland Cavulus On Fri, Feb 25, 2022 at 9:00 AM Kafka Life wrote: > Dear Experts > > do you have any solution for this please > > On Tue, Feb 22, 2022 at 8:31 PM Kafka Life wrote: > > > Dear Kafka Experts >

Re: Kafka streams and user authentication

2022-02-25 Thread Guozhang Wang
Got it. I'm not totally sure how the spring wires the properties from the file to the actual configs in Streams, but just a general suggestion: in Kafka Streams you can specify the config overrides for the internally embedded producer and consumer respectively: https://kafka.apache.org/10/document

Re: KAFKA- UNDER_REPLICATED_PARTIONS - AUTOMATE

2022-02-25 Thread Kafka Life
Dear Experts do you have any solution for this please On Tue, Feb 22, 2022 at 8:31 PM Kafka Life wrote: > Dear Kafka Experts > > Does anyone have a dynamically generated Json file based on the Under > replicated partition in the kafka cluster. > Everytime when the URP is increased to over 500 ,