Re: Kafka topic __consumer_offsets replication issue

2023-04-29 Thread kiran kumar
Hello All, Any insights on this issue? Thanks, Kiran On Sun, 23 Apr 2023 at 1:58 PM, kiran kumar wrote: > Hello Kafka Folks, > > I have encountered an issue with Kafka 3.2 version. > Environment: > OS: RHEL 7.9 > Java: 1.8 > Kafka: 3.2 > > There seems to one

Kafka topic __consumer_offsets replication issue

2023-04-23 Thread kiran kumar
Hello Kafka Folks, I have encountered an issue with Kafka 3.2 version. Environment: OS: RHEL 7.9 Java: 1.8 Kafka: 3.2 There seems to one of the replica is stuck in __consumer_offsets topic. I have the replication factor set as 3 and its 5 node kafka cluster. I could see that out of 2 replicas on

Re: Kafka topic data automatically restore after deleting topics

2019-02-12 Thread kiran kumar
if you want to delete the messages from topic you can use kafka-delete-records.sh. I guess thats whay you are looking for. Thanks, Kiran On Mon, 4 Feb 2019 at 11:34 AM, Soheil Pourbafrani wrote: > I'll try it > For your information, I connect another single node Kafka to the same > Zookeeper cl

Re: Upgrading Kafka to 11.0

2017-09-12 Thread kiran kumar
Thanks Mani. On Tue, Sep 12, 2017 at 12:27 PM, Manikumar wrote: > Hi, > > Yes, you can replace bin and libs folders. or you can untar to a new folder > and > update config/server.properties config file. > > On Tue, Sep 12, 2017 at 12:21 PM, kiran kumar > wrote: >

Re: Upgrading Kafka to 11.0

2017-09-11 Thread kiran kumar
ep 8, 2017 at 10:22 PM, kiran kumar wrote: > Hi All, > >1. Upgrade the brokers one at a time: shut down the broker, update the >code, and restart it. > > What does it mean to "update the code". > Does it mean replace the old lib folder with latest ? or rep

Upgrading Kafka to 11.0

2017-09-08 Thread kiran kumar
Hi All, 1. Upgrade the brokers one at a time: shut down the broker, update the code, and restart it. What does it mean to "update the code". Does it mean replace the old lib folder with latest ? or replace lib and bin with latest? Could someone clarify ? Thanks, Kiran

Re: Kafka ACL's with SSL Protocol is not working

2016-12-15 Thread kiran kumar
I have just noticed that I am using the user which is not configured in the kafka server jaas config file.. On Thu, Dec 15, 2016 at 6:38 PM, kiran kumar wrote: > Hi Raghu, > > I am also facing the same issue but with the SASL_PLAINTEXT protocol. > > after enabling debug

Re: Kafka ACL's with SSL Protocol is not working

2016-12-15 Thread kiran kumar
Hi Raghu, I am also facing the same issue but with the SASL_PLAINTEXT protocol. after enabling debugging I see that authentication is being completed. I don't see any debug logs being generated for authorization part (I might be missing something). you can also set the log level to debug in prop

this server does not host this topic-partition.

2016-11-18 Thread kiran kumar
Hi All, How to recover the broker from the following errors: ERROR [ReplicaFetcherThread-0-28], Error for partition [_confluent-controlcenter-0-MonitoringStream-ONE_HOUR-changelog,4] to broker 28:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic

enabling acl's restricts the plaintext protocol too

2016-11-18 Thread kiran kumar
Hi All, Is it possible to connect producers/consumers over a plaintext protocol with the following broker configuration ? broker config: plaintext:host-name:9091,sasl_plaintext:host-name:9092 *allow.everyone.if.no.acl.found=true* authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer sec

Re: Kafka error: FATAL Fatal error during KafkaServerStartable startup.after enabling security

2016-05-27 Thread kiran kumar
gt; to get SASL debug messages. > > Alex > > On Fri, May 27, 2016 at 5:38 AM, kiran kumar > wrote: > > > Hello All, > > > > After enabling the security for the kafka brokers and zookeeper, I am > > unable to start the kafka brokers. > > > > I