Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to start spring application even if Kafka listener (spring-kafka) doesn't initialize

Communication among microservices: Apache Kafka vs Hazelcast's Topic

Exception when processing data during Kafka stream process

How can do Functional tests for Kafka Streams with Avro (schemaRegistry)?

Get last modified date of a Kafka topic

apache-kafka

Kafka-docker container scaling failed for wurstmeister with error as "advertised listeners are already registered by broker 1001"

One or more schemas per topic when using Schema Registry with Kafka, and Avro...?

How to start Kafka listener manually?

Is there a way to determine where messages came from in a Kafka topic?

apache-kafka

Intermittent WARN ConsumerCoordinator We received an assignment that doesn't match our current subscription

How to create a scala object in clojure

scala clojure apache-kafka

How to send output of two different Spout to the same Bolt?

kafka ktable - rocksdb access via java

How to enable GC logging for Apache Kafka brokers, while preventing log file overwrites and capping disk space usage

Why single node multiple broker in kafka cluster not preferred?

Issue with ArrayList Serde in Kafka Streams API

How to produce messages with headers in Kafka 0.11 using console producer?

apache-kafka

if i set value of commit.interval.ms = in kafka stream, Whether it will be able to commit offset?

How to transactionally poll Kafka from Camel?

Is it possible to have one Kafka consumer thread per topic?