Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to evenly distribute messages over partitions in Kafka?

apache-kafka

Do newer versions of Kafka producers still have "producer.type"?

java apache-kafka producer

How to read binary data on Kafka topics in Spark

Kafka consumer - assign and seek

How to solve ERROR Executor - Exception in task 0.0 in stage 20.0 (TID 20)?

Microservices, REST, event sourcing and data consistency

Converting Spark-kafka InputDStream to Array[Bytes]

Spark Streaming and ElasticSearch - Could not write all entries

How many times kafka stream invokes poll() for fetching records from kafka topic

Kafka PointToPoint

java jms apache-kafka

Kafka consuming the latest message again when I rerun the Flink consumer

apache-kafka apache-flink

Not able to run Kafka Connect in distributed mode - Error while attempting to create/ find topics 'connect-offsets'

Exception: partition is not a recognized option, when creating a kafka topic inside a docker.

Clarification on the --broker-list option and --bootstrap-server option in Kafka-console producer and consumer respectively

apache-kafka