Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to implement "debouncing" for event-driven microservices?

How to implement change data capture (CDC) using Kafka Connect for Sybase ASE database?

Access "bitnami/kafka" docker container from everywhere

How to get latest offset/size of a Kafka topic using KafkaAdminClient (Java) for 2.x version

java apache-kafka

Kafka transactions on multiple clusters

apache-kafka

Error: Invalid value "sasl_ssl" for configuration property "security.protocol")

How to de-normalize data in Kafka?

How to deduplicate messages while streaming kafka using Spark Streaming?

Postgres replication slot from kafka-connect is filling up

How to use transactions in Kafka and how to use abortTransaction?

Confluent Platform in Windows

Kafka transactionLog fails with NotEnoughReplicasException, despite correct config

apache-kafka

Run Confluent JDBC Connector at specific time instead of using polling interval?

Why kafka-avro-console-producer doesn't honour the default value for the field?

How Kafka consumer works if consumers are more that partitions

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