Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

KafkaStreamsStateStore not working when the store value is an Avro SpecificRecord

kafka jdbc source connector: time stamp mode is not working for sqlite3

Can Kafka be asked to wait less than max.poll.interval.ms during a JoinGroup?

apache-kafka

How to get Kafka connection state without parsing the log file? To be able to take action on "Connection to node terminated during authentication."

Flink Python Datastream API Kafka Consumer

How to modify message from Twitter API saved in one kafka topic and send it to another kafka topic

Kafka compaction for de-duplication

apache-kafka

avro events from kafka to HDFS with flume

Node Kafka - Duplicate messages are coming

How to run kafka producer in eclipse?

eclipse apache-kafka

Send Record with JSON Schema to Kafka using Spring-Kafka and Confluent schema registry

Kafka .net client does not receive any messages when using Assign()

Spark Structured Streaming - Processing each row

Kafka Producer in .Net - SSL Handshake Failed