Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Running a distributed kafka connect cluster on AWS ECS

java.lang.ClassNotFoundException: org.apache.kafka.common.metrics.MetricsContext

Kafka retries config and performance implications

Fault Tolerance of FlinkKafkaConsumer in HiBench

Too many open files Kafka Exception on running for long

Why is there no Async / Non-Blocking Support in Kafka Streams API?

KafkaUtils API | offset management | Spark Streaming

Consumer gives "This server does not host this topic-partition" error

Kafka docker compose external connection [duplicate]

Debezium: No maximum LSN recorded in the database; please ensure that the SQL Server Agent is running

Kafka Consumer Group Id and consumer rebalance issue

How does Debezium set the Kafka message timestamp

apache-kafka debezium

kafka node js client compression issue with snappy

kafka connect exception, Replication factor: 3 larger than available brokers: 1

When Kafka sends multiple batches in the same request?

apache-kafka

org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server will accept

Converting Java to Avro and back when using kafka

java apache-kafka avro