Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Kafka check queue size

how to fetch a field in ConsumerRecord

Kafka Stream from JSON to Avro

Not able to connect to wurstmeister/kafka

spark streaming assertion failed: Failed to get records for spark-executor-a-group a-topic 7 244723248 after polling for 4096

For AvroProducer to Kafka, where are avro schema for "key" and "value"?

Event Sourcing: concurrently creating conflicting events

How to convert bytes from Kafka to their original object?

Java Kafka consumer group failing to consume a few messages

java apache-kafka

Using Spark Structured Streaming to Read Data From Kafka, Issue of Over-time is Always Occured

Messaging platform with QoS / Kafka partition overloading

apache-kafka messaging

How to get windowed aggregation from kafka stream?

How to use maxOffsetsPerTrigger in pyspark structured streaming?

pyspark apache-kafka

Sending Apache Kafka data on web page

bootstrap-server vs zookeeper params in consumer console

Kafka KStream-KTable join race condition

Getting broker configuration via kafka-configs.sh

apache-kafka

Is it possible to ReKey a GlobalKTable?

IllegalStateException: _spark_metadata/0 doesn't exist while compacting batch 9

Kafka consumer group script to see all consumer group not working

apache-kafka