Sep 3, 2020 · I'm getting the error: org.apache.kafka.common.errors.TimeoutException: Topic testtopic2 not present in metadata after 60000 ms. When trying to produce to the topic in my …

The application comes with a /config directory containing a lot of files used for configuration purposes but none that are for Java. It also comes with a /bin directory containing a bunch of …

Mar 28, 2020 · I'm running kafka 2.13-2.4.1 and configuring an SSL connection between kafka client (consumer) written in java and a kafka cluster (3 nodes with each node having one …

Aug 21, 2024 · 51 I'm writing a kafka consumer using Java. I want to keep the real time of the message, so if there are too many messages waiting for consuming, such as 1000 or more, I …

Kafka Consumers handles the data backlog by the following two parameters, max.poll.interval.ms The maximum delay between invocations of poll () when using consumer group management. …

Oct 2, 2018 · For example: In Apache Kafka Documentation page it says: Java 1.8, however in their release notes for v2.0 I see the bug fixes and improvement like: [KAFKA-6855] - Kafka …

I'm using Heroku Kafka, which is running 0.10.1.1 and uses SSL. They only support the latest protocol. Heroku Kafka uses SSL for authentication and issues and client certificate and key, …

Dec 14, 2018 · ERROR Exiting Kafka due to fatal exception (kafka.Kafka$) on Windows - Apache Kafka Asked 6 years, 10 months ago Modified 3 months ago Viewed 26k times

When you run > bin/kafka-console-consumer.sh command kafka loads a ConsoleConsumer, which will attempt to create a consumer with an auto generated consumer id. The way Kafka …

Aug 1, 2018 · I setup a single node Kafka Docker container on my local machine like it is described in the Confluent documentation (steps 2-3). In addition, I also exposed Zookeeper's …