Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Write to two Kafka topics in a single transaction using Spring Kafka

Shaded/Repackaged jar as a dependency

Kafka 0.8, is it possible to create topic with partition and replication using java code?

apache-kafka

Kafka-connect sink task ignores file offset storage property

In-memory vs persistent state stores in Kafka Streams?

Is Old Kafka written in Scala and new Kafka written in Java?

apache-kafka

KafkaConsumer position() vs committed()?

Kafka single consumer failure in a group

apache-kafka

Retry logic in kafka consumer

Why do we need kafka to feed data to apache spark

get current config in kafka

Invoking non-blocking operations sequentially while consuming from a Flux including retries

Apache Kafka Streams Materializing KTables to a topic seems slow

Kafka data types of messages

Spark Streaming: Micro batches Parallel Execution

Spring Boot containers can not connect to the Kafka container

aborting kafka reassign partition action

apache-kafka

How to create InputDStream with offsets in PySpark (using KafkaUtils.createDirectStream)?

Error UNKNOWN_MEMBER_ID occurred while committing offsets for group xxx

Problems with the retention period for offset topic of kafka