kafka-consumer-api Archives

Partition structure for 2 kafka consumers on same topic

Java June 1, 2020

If I create 2 kafka consumer instances passing same properties subscribe on same topic Will these 2 Consumer instances (at diff group Id), have similar partition structures, or could be different ? …

Kafka Streams API: Session Window exception

Java May 19, 2020

I am trying to create a Kafka topology and break it down into more readable. I have a stream that I group by keys, and then I am trying to window it like so: SessionWindowedKStream

How to get message Apache Kafka on client JS?

JavaScript July 13, 2019

Can Apache Kafka send message from server broker to client side (JS) directly? Or I should use socket pipe?

What is the difference between implementing Deserializer and Serde in Kafka Consumer API?

Java May 24, 2019

I try to simulate Gwen (Chen) Shapira’s kafka-clickstream-enrich kafka-stream project on GitHub (https://github.com/onurtokat/kafka-clickstream-enrich). When I consume a topic using consumer class …

Kafka – shutting down (kafka.server.KafkaServer), problems with starting Kafka-Server-Start

Java December 9, 2014

I’ll start from the beginning. I have openSuse 13.2, i also have jdk_1.7.0_51, scala-2.11.4 and gradle-2.2.1. I have downloaded source of kafka-0.8.2-bet-src and run ./gradlew commands as they where …