Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

Magic byte in Apache Kafka

Kafka and Akka Cluster

How to put data from MySQL to Kafka producer? [closed]

Kafka Streams with lookup data on HDFS

Bidirectional messaging system using kafka

Kafka Streams - what is stored in memory and disk in Streams App

How to set offset in kafkalistener

CQRS: project out-of-order notifications in an ElasticSearch read model

Why does Kafka Direct Stream create a new decoder for every message?

use of "default" in avro schema

Testing window aggregation with Kafka Streams

How can I assure consistency when using an event-carried state transfer approach in Kafka

Kafka JDBC Sink Connector: no tasks assigned