Take a look at the new AdminClient or KafkaAdminClient classes
https://kafka.apache.org/24/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html
https://kafka.apache.org/24/javadoc/org/apache/kafka/clients/admin/AdminClient.html
You can describe the topic or topics in question and it shoul
Hi All,
we are running Kafka Connect in a distributed mode with Debezium (Mongo) as
a source and Confluent S3 connector as a sink. When add a new connector via
the REST API the connector is created in RUNNING state, but no tasks are
created for the connector. When we stop all workers and then star
Dear sir,
I am new to Apache Kafka. I am developing an application in which Apache
kafka is working as broker. I am producing random data using Spring Boot
application and inserting it to PostgreSQL's TimeScale Database using
Telegraf plugin and Kafka broker.
While I am running my application and
Hi team,
Need a kafka compatibility metrics details
*Thanks and regards,*
*Ajith Kumar Rajendran*
*+91 9080451861*
