Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to consume messages from Kafka in Java, starting from a specific offset

How to pause a kafka consumer?

Unable to create topic when kafkaProducer tries to send record for the first time INVALID_REPLICATION_FACTOR

Consumer group has no active members - Kafka

apache-kafka

Who keeps track of the last read message offset of the consumer in Apache Kafka?

Embedded Kafka Spring test executes before embedded Kafka is ready

How long does KTable data maintain in Kafka? Or how can I control the time

How does a Kafka producer behave during a network partition?

apache-kafka

kafka: different offsets for one topic

java apache-kafka

IoT - multiple Kafka producers to publish messages to same topic

Kafka Connect Schema evolution when columns are removed

kafka retention policy didn't work as expected

apache-kafka

Consumer 'group_name' group is rebalancing forever

The kafka script kafka-consumer-group.sh throws timed out waiting for a node assignment

java apache-kafka

Create Kafka topic in Docker works from command line but not from Shell script file

How to solve zookeeper.properties file is missing error

mkdir: cannot create directory '/bitnami/kafka/config': Permission denied