sxganapa

Even I have irregular consumption of partition, so the lag in certain partitions are more. What is the reason for this? How can we fix this?

@sergeykranga can you help me? I have about 3400 partitions on 30 different topics. My s3.part.size is 5MB. I have 30 tasks(1 task for each topic) across 2 worker nodes...

@sergeykranga thank you. I am using TimeBasedPartitioning with wall clock as the timeextractor. Also 510 Gb is it across all nodes or just one node. Also is this max heap...

I have 1 tasks and the topic has got 140 partitions. I see lot of consumer lag more that 20 hours. goes beyond our retention time.Hence losing data. how to...

I am having issue of losing datal when sending to s3 buckets.I have no exception in the logs, except for WARN message Commit of offsets timed out in the logs....

I am also getting FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler) when using Kafka connect. Can some one explain what this means? I am on 2.3 version of Kafka.

How can I information on who has logged on to the Kafka Manager Ui? We need to track the people who are using the kafka manager ui What we need...

Please share the jaas config file and also how to enable the logging so that I can view who has logged in.

Does Kafka manager support multiple user logins and also I want to store the login info for audit trail purpose?