Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

[HDFS connector + Kafka]How to write multiple topics in standalone mode?

Spring Kafka. Not started EmbeddedKafkaBroker

What is the use of Header in Kafka Processor API?

How to connect to Kafka cluster with Kerberos Authentication on Windows using the Cofluent library?

Is an upsert possible with Kafka Connect to ElasticSearch

Kafka API: java.io.IOException: Can't resolve address: 357d78957cf5:9092

scala apache-kafka

kafka java client not consuming - just hangs at consumer.poll

How to know when consumer.poll() is called while using @KafkaListener annotation?

Differences between zookeeper-server-start.sh and kafka-server-start.sh

Kafka Json consumer error java.lang.NoSuchFieldError: READ_UNKNOWN_ENUM_VALUES_USING_DEFAULT_VALUE

Can I apply graceful shutdown when using Spring Cloud Stream Kafka 3.0.3.RELEASE?

Spring and Kafka - Multiple Consumers with same Group ID - Only one consumer gets the messages

Spark: cast bytearray to bigint