Question - Partition Lag

Hello users. We have a 7 broker cluster running 0.11.0.2. We are seeing an issue with one of the partitions in a topic. We see lag on that partition even though there are many consumer threads available to process the messages. Any inputs/thoughts? Here is the metadata Topic:topic_name Partit

Question - Partition Lag

Hello users. We have a 7 broker cluster running 0.11.0.2. We are seeing an issue with one of the partitions in a topic. We see lag on that partition even though there are many consumer threads available to process the messages. Any inputs/thoughts? Here is the metadata Topic:topic_name Partit

Re: Question - Partition Lag

consumers are blocking or taking a very long time to > process consumed records. I'd suggest implementing indepth logging of your > consumers to investigate their performance. > >> On Sat, 21 Jul. 2018, 11:51 am Antony A, wrote: >> >> Hello users. >> >

kafka security using ssl

Hi, I have followed the steps to secure the brokers using SSL. I have signed the server certificate using internal CA. I have the keystore with server certificate, private key and the CA. Also the truststore has only the CA. Unfortunately I am unable to start the broker with the following server

Re: kafka security using ssl

uent.io/current/kafka/authentication_ssl.html. > > i would verify them and see if you're using the same configuration and > properly setup certificate stores. > > I hope it helps, > > -- Pere > >> On Thu, 22 Aug 2019, 05:49 Antony A wrote: >> >> Hi, >

Re: kafka security using ssl

trust store? > >> On Thu, 22 Aug 2019, 14:40 Antony A wrote: >> >> Hi, >> >> I was able to get the broker running if I used a CA created as shown in >> the example below. https://kafka.apache.org/documentation/#security_ssl >> >> The issue I am faci

Re: kafka security using ssl

it > properly signed with the ca? can you share as well the current error. > > -- Pere > > On Thu, 22 Aug 2019, 14:47 Antony A wrote: > > > Yes. The truststore has the CA. The keystore has the CA, PRIVATE KEY used > > to create the CSR and the SERVER CERT. > > &

Re: kafka security using ssl

curity-playbook/blob/master/tls/server.cnf#L25 > > Missatge de Antony A del dia dj., 22 d’ag. 2019 a > les 16:50: >> Is ExtendedKeyUsages an issue for Kafka? >> >> #7: ObjectId: 2.5.29.37 Criticality=false >> ExtendedKeyUsages [ >> serverAuth >

Kafka 2.3 - SASL_SSL

Hi, I have configured the brokers and zookeepers as below to enable SSL and authentication with SASL/Kerberos. I have tried with and without advertised.listeners, advertised.host.name, host.name, port. *server.properties* listeners=SASL_SSL://:9092 advertised.listeners=SASL_SSL://:9092 advertis

Re: Kafka 2.3 - SASL_SSL

Hi, I am trying to authenticate with "super" user - admin as per the above configuration. Is this possible with only "SASL_SSL" listeners? Or should I have a "PLAIN" listener as well to authenticate with super user account? Thanks On Thu, Aug 29, 2019 at 8:43 PM

Kafka Broker - High CPU

Hi, I am running Kafka 1.0.1 on a 7 broker cluster. On one of the brokers the CPU usage is always pegged around 98% utilization. If anyone had similar issues, please can you comment on it? Thanks, AA

Re: Kafka Broker - High CPU

show with the highest CPU? > > On Fri, Sep 27, 2019 at 12:35 PM Antony A > wrote: > > > Hi, > > > > I am running Kafka 1.0.1 on a 7 broker cluster. On one of the brokers the > > CPU usage is always pegged around 98% utilization. If anyone had similar > > issues, please can you comment on it? > > > > Thanks, > > AA > > >