Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

When to use Kafka transactional API?

Disperse messages in Kafka stream

Alternate for polling Kafka server

Is it possible to change the replication factor of an existing kafka topic using java?

java apache-kafka

Kafka client unit testing for dotnet

kafka.server.KafkaServerStartable - java.lang.OutOfMemoryError: Java heap space

How to disable JSON schema in Kafka Source Connector (e.g. Debezium)

opensource tool for Oracle Change data capture - Alternative to GoldenGate

Where does Confluent's kafka-avro-console-consumer write its log files?

How to migrate Kafka from old Zookeeper cluster to new Zookeeper cluster with different znode parent path

Get latest values from a topic on consumer start, then continue normally

Kafka increasing processing timeout message

My Kafka consumer retry for 10 times abnormally, and stop its retrying by simply adding a MDC log?

Kafka : Update jaas config dynamically

Should I create more topics or more partitions?

Spring Kafka test with embedded Kafka failed on deleting logs

How to install connectors to the docker image of apache kafka connect

What is the proper way to check kafka cluster health?

Kafka producer config to send a message immediately

java apache-kafka

Can Debezium Capture Changes of a Postges Materialized View