Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in apache-kafka

Spark Scala Jaas configuration

scala apache-spark apache-kafka jaas

How to test a ConsumerAwareRebalanceListener?

java spring-boot testing apache-kafka spring-kafka

KafkaStreams How to specify Serdes in stream aggregation?

java apache-kafka apache-kafka-streams

kafka connect - jdbc sink sql exception

apache-kafka apache-kafka-connect confluent-platform

Why is the "topics" argument of KafkaUtils.createStream() a Map rather then array?

java apache-spark apache-kafka spark-streaming

Getting schema deserialisation error : Invalid default for field

serialization apache-kafka deserialization avro confluent-schema-registry

Spark-Streaming hangs with kafka starting offset at earliest (Kafka 2, spark 2.4.3)

apache-spark apache-kafka kafka-consumer-api spark-structured-streaming

MacOS throwing dyld Error when running kafkacat

macos apache-kafka kcat

Kafka design questions - Kafka Connect vs. own consumer/producer

apache-kafka kafka-consumer-api apache-kafka-connect kafka-producer-api

How to check the actual number of incremental fetch session cache slots used in Kafka cluster?

apache-kafka

How to write Kafka Producer in Scala

scala apache-spark apache-kafka kafka-producer-api

BufferError: Local: Queue full in Python

python apache-kafka

Send message to different Kafka topics based on configuration

java apache-kafka

Issue in connecting kafka from outside

hadoop cloudera apache-kafka hortonworks-data-platform

How to set offset committed by the consumer group using Spark's Direct Stream for Kafka?

java apache-spark apache-kafka spark-streaming

Broker replication error "Not authorized to access topics: [Topic authorization failed.] "

apache-kafka

How to reconnect kafka producer once closed?

java multithreading scala apache-kafka

Is it possible to disable caching for some kafka topics?

apache-kafka

What is the reasoning behind Kafka Connect Schemas?

apache-kafka avro apache-kafka-connect confluent-schema-registry

Kafka instead of Rest for communication between microservices

rest apache-kafka microservices
« Newer Entries Older Entries »