Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

what is the difference between kafka ProducerRecord and KeyedMessage

Deserialize Avro messages into specific datum using KafkaAvroDecoder

java apache-kafka avro

Spring kafka Consume multiple Message types in one consumer

java spring apache-kafka

Exception while accessing KafkaOffset from RDD

Desigining Kafka Topics - Many Topics vs One Big Topic

kafka Multi-Datacenter with high availability

apache-kafka

Not able to start kafka with .\bin\windows\kafka-server-start.bat .\config\server.properties cmd

apache-kafka wmic

Kafka Consumers throwing java.lang.OutOfMemoryError: Direct buffer memory

Kafka not able to consume without reading from beginning -Java

How to assign client-id to a particular kafka producer or topic?

Kafka - Multiple consumers (only one active) on same group/topic

apache-kafka mapr-streams

Can Kafka be provided with custom LoginModule to support LDAP?

apache-kafka ldap jaas sasl

Reading data from _transaction_state topic in Kafka 0.11.0.1

Apache Kafka - Autocommit = false and no commit

How to do content filtering with Apache Kafka?

java apache-kafka

Kafka Connect JDBC Source Connector not working for Microsoft SQL Server

Delete Messages from a Topic in Apache Kafka

java apache-kafka

Kafka-Streams Join 2 topics with JSON values | backpressure mechanism?

How to set kafka-connect connector and task's JVM heap size?

How can I control the number of output files written from Spark DataFrame?