Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to clear topics in tests with Spring Kafka

Create kafka connector with the name which is not already in use

Exception Handling on sending a message via Kafka Template

No pending reply: ConsumerRecord

Kafka: Consume partition with manual batching - Messages are being skipped

Kafka does not start blank output

Kafka consumer fails silently to connect to broker

apache-kafka spring-kafka

How do I connect to a Kerberos-secured Kafka cluster with Spark Structured Streaming?

How to preserve the field case sensitivity in ksql while creating the stream form schema registry by specifying the topic name

apache-kafka ksqldb

When does Kafka rotates partition leader? Do we have any property to control it?

apache-kafka

Could not find kafka-clients-test.jar (org.apache.kafka:kafka-clients:0.10.2-kafka-2.2.0)

Does ConcurrentKafkaListenerContainerFactory increases parallelism in consumption of messages from Kafka Topics

Issue with Apache Kafka server start

apache-kafka

console-producer Error connecting to node kafka1:9092 (org.apache.kafka.clients.NetworkClient) java.net.UnknownHostException

what is this topic "__consumer_offsets" in Kafka

apache-kafka

Axon or Kafka to support CQRS/ES

Quarkus Kafka Deserializing Exception to Dead Letter Queue

kafka cluster expansion generic step

apache-kafka

End-to-end Exactly-once processing in Apache Flink