Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Difference between Spring Kafka lib and native Kafka Java API

apache-kafka spring-kafka

How to deserialize BigDecimal value received from kafka broker through debezium CDC mechanism?

kafka-node several consumers

node.js apache-kafka

Clojure: implementing stateful Java interface

Kafka server not starting on windows, kafka-server-start.bat returning no output

windows apache-kafka

Is Kafka a Message Queue or a Message Broker? [closed]

Adding ConsumerRebalanceListener to the ConcurrentKafkaListenerContainerFactory

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?