Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

How to send and consume json messages using confluent-kafka in Python

No JAAS configuration section named 'Server' was foundin '/kafka/kafka_2.12-2.3.0/config/zookeeper_jaas.conf'

Kafka stream: "TopicAuthorizationException: Not authorized to access topics" for an internal state store

How can I disable spring cloud stream for development purpose when there are not kafka broker running?

Filter the records by a certain value in kafka connect