Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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

Kafka Serialization of an object [duplicate]

Best practice for integrating Kafka and HBase

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?