New posts in apache-kafka

How to commit manually with Kafka Stream?

apache-kafka apache-kafka-streams

How to write kafka record key to separate column (not primary key) by JDBC sink connector?

postgresql jdbc apache-kafka apache-kafka-connect

Kafka RangeAssignor benefits over RoundRobin

Can multiple Kafka consumers read same message from the partition

apache-kafka kafka-consumer-api

ClassNotFoundException exception occurred: io.confluent.kafka.security.config.provider.SecurePassConfigProvider (kafka.server.KafkaConfig)

apache-kafka confluent-platform apache-kafka-security

How can I access the list of uncommitted messages in a topic in kafka?

apache-kafka confluent-kafka-dotnet

When/how does a topic "marked for deletion" get finally removed?

Kafka or SNS or something else? [closed]

amazon-web-services amazon-sqs apache-kafka

Debezium Error : ConnectException: Data row is smaller than a column index

sql-server apache-kafka apache-kafka-connect debezium

Retrieve always latest messages from Kafka on reconnection

c++ apache-kafka librdkafka

Delete message after consuming it in KAFKA

apache-kafka kafka-consumer-api

Writing Custom Kafka Serializer

java scala serialization apache-kafka

How to check if ZooKeeper is running or up from command prompt?

hadoop config apache-zookeeper apache-kafka ps

How to view kafka message

How to change the number of replicas of a Kafka topic?

I can't run Kafka on windows

windows apache-kafka apache-zookeeper

kafka broker connection failed when create new topic with a cluster of 3 brokers

docker apache-kafka docker-compose

Registering kafkalistenerContainers with KafkaListenerEndpointRegistry

java spring-boot apache-kafka spring-kafka

How to tell spring-kafka consumer to stop consuming, at runtime?

apache-kafka spring-kafka

Kafka consumer list

apache-kafka kafka-consumer-api