Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Multiple windows of different durations in Spark Streaming application

kafka cluster configuration

Kafka connector- cannot stop rebalancing

Spring Cloud Stream dynamic channels

error: package org.apache.kafka.clients.producer does not

Spark-Streaming Kafka Direct Streaming API & Parallelism

Kafka Consumer: Stop processing messages when exception was raised

One kafka consumer for multiple topics vs one consumer for each topic/partition

apache-kafka

Understand Kafka write speed

Spark Structured Streaming Checkpoint Compatibility

100% cpu usage by all kafka brokers

apache-kafka

Kafka Consumer needs a long poll duration

kafka new version 2.1.0 broker hangs for no reason

Embedded Kafka for testing without spring [closed]

Delaying Kafka Streams consuming

What is the best practice for keeping Kafka consumer alive in python?

java.lang.ClassNotFoundException: com.fasterxml.jackson.databind.ser.FilterProvider when flink boot up

Uber-go/zap and kafka-go race condition

Kafka Zookeeper connection issues

Unable to communicate with kafka server using kafka Producer API