Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Why calls to seekToBeginning and seekToEnd APIs of Kafka hang forever?

java apache-kafka

Using Kafka's Log Compaction, what can I do to guarantee consumers don't miss messages, if they are not lagging behind by some defined timelimit?

how to send message to kafka topic protected with SSL

How can I solve this no such file log error in Kafka quickstart?

logging apache-kafka

How should I connect clickhouse to Kafka?

apache-kafka clickhouse

Spark Structured Streaming: StructField(..., ..., False) always returns `nullable=true` instead of `nullable=false`

KafkaListener with long tasks in Spring Boot Service

kafka Offset commit failing org.apache.kafka.clients.consumer.CommitFailedException

How to connect from spring boot kafka project to aws MSK

How to access SASL configure kafka from Kafka cli

apache-kafka sasl

Kafka Connect, plugin path

Flink checkpoints keep failing (Timeout while awaiting InitProducerId)

apache-kafka apache-flink

Kafka fetch.max.bytes vs max.partition.fetch.bytes understanding

apache-kafka

Kafka ACL: wildcard(*) suffixed topic name support

apache-kafka acl

How to configure Apache Kafka to sending data at specified time?

Kafka new consumer: (re)set and commit offsets with using assign, not subscribe