Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

retrieve messages in a topic using kafka-python

How to create a list of topics in Apache Kafka using single command

Running kafka connect in Distributed mode?

kafka bootstrap.servers as DNS A-Record with multiple IPs

Kafka consumer not consuming from beginning

Py4JJavaError: An error occurred while calling o45.load. : java.lang.NoClassDefFoundError: org/apache/spark/sql/sources/v2/StreamWriteSupport

Is there a limit on consumers and consumer groups?

apache-kafka

Spring Kafka - How to set Commit Async property

How to map input KStream <String,String> into <String, CarClass> using KeyValueMapper?

Getting the last message sent to a kafka topic

Kafka Log4j appender not sending messages

java log4j apache-kafka

Kafka Mirror Maker 2 Offset Replication Not Working

launching multiple kafka broker fails

Running a distributed kafka connect cluster on AWS ECS

java.lang.ClassNotFoundException: org.apache.kafka.common.metrics.MetricsContext