Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Return from Kafka consumer when there is no message

Flink+Kafka reset checkpoint and offset

How Kafka leader replica decides to advance Highwater Mark (HW) when replicating data to follower replicas

Kafka Connector to IBM DB2

mongodb apache-kafka ksqldb

Consuming messages in batch in Kafka using @KafkaListener

Structured Streaming error py4j.protocol.Py4JNetworkError: Answer from Java side is empty

Sarama cannot talk to the Kafka server

go apache-kafka sarama

Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties

How to run a Kafka Canary Consumer

Spring Kafka ChainedKafkaTransactionManager doesn't synchronize with JPA Spring-data transaction

Is it possible to deserialize Avro message(consuming message from Kafka) without giving Reader schema in ConfluentRegistryAvroDeserializationSchema

Value split is not a member of (String, String)

How to connect to external Oracle database in Docker

Spring Boot Job scheduler with Kafka consumer

Ruby Kafka Uncaught exception: Failed to find group coordinator

How to generate pojo from kafka avro record?

Is there a way to configure JMeter to listen to a kafka topic?

jmeter apache-kafka

Microservices: API Call Vs Messaging. When to Use?

Maximum value for zookeeper.connection.timeout.ms

Kafka connection transformations. Parse input string and get a record key