Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

How to decode Kafka messages using Avro and Flink

Debezium Kafka CDC connector making key as avro even when converter is StringConverver

Kafka high-level consumer: Can partitions have multiple threads consuming it?

Kafka force JKS re-load

java apache-kafka

Getting acks = -1 when I set acks to all in my Kafka producer

what's the difference between kafka-preferred-replica-election.sh and auto.leader.rebalance.enable?

apache-kafka

Moving data from Snowflake to Kafka

Spring Integration Kafka Consumer

Kafka topic not created automatically on remote kafka after spring boot start(and create on local kafka server)

Apache Flink delay processing of certain events

Get kafka record timestamp from kafka message

scala apache-kafka

How to get full document when using kafka mongodb source connector when tracking update operations on a collection?

Consumer connecting to zookeeper not broker for message consumption?

java apache-kafka

How to measure the performance metrics on kafka when pushing/consuming the message to/from the topic

apache-kafka

How can I send data from kafka to hive

hive apache-kafka

Kafka s3 connect "Value is not Struct type" error

Spark (Kafka) Streaming Memory Issue