apache-kafka-streams Examples and Free Source Code

How to lookup dynamically in a KTable?...

apache-kafka apache-kafka-streams

KTable with billions unique keys...

apache-kafka-streams

Kafka Streams - Relation between "Stream threads" vs "Tasks" running on 1 C4.XLa...

apache-kafka apache-kafka-streams

Do i need to register schema for kafka stream changelog topic under schema registry?...

java apache-kafka apache-kafka-streams confluent-schema-registry

Using kafka streams trying to write messages from input topic to output topic...

apache-kafka kafka-consumer-api apache-kafka-streams kafka-producer-api

Specifying serdes on a map operation in Kafka Streams...

apache-kafka avro apache-kafka-streams

Spring Cloud Stream Kafka Consumer application doesn't allow adding Supplier...

avro apache-kafka-streams spring-cloud-stream kafka-producer-api confluent-schema-registry

Kafka Stream-GlobalKTable join on a specific field...

java apache-kafka apache-kafka-streams

Kafka join storage...

apache-kafka apache-kafka-streams

How do KTables interact with Kafka on startup?...

apache-kafka apache-kafka-streams

How to deserialize MessagePack in Spring Cloud Stream App...

java apache-kafka apache-kafka-streams spring-kafka spring-cloud-stream

Does kafka holds capability of rule-engine?...

apache-kafka apache-kafka-streams

Spring Boot application using the Spring Cloud Stream Kafka Binder + Kafka Streams Binder not workin...

spring-boot apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka

java.lang.NoSuchMethodError: org.apache.kafka.common.metrics.Sensor.add error in kafka streams...

apache-kafka-streams

java.lang.ClassCastException: class .$Proxy143 cannot be cast to class .MessageChannel (... are in u...

spring-cloud apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka

kafka-streams: retry complete message join if single element is missing...

apache-kafka apache-kafka-streams

How to remove old records from a state store using a punctuator? (Kafka)...

java apache-kafka apache-kafka-streams ktable

Query KTable in the same Application where it is created...

apache-kafka-streams ktable

Kafka Streams: Should we advance stream time per key to test Windowed suppression?...

java apache-kafka apache-kafka-streams

how to process data in chunks/batches with kafka streams?...

java scala apache-spark apache-kafka apache-kafka-streams

Kafka Streams DSL folding hierarchical data...

apache-kafka apache-kafka-streams

Dynamically materialize KTable aggregate to different state stores...

apache-kafka-streams spring-cloud-stream

Spring Cloud Stream Kafka Streams Binder 3.x: No output to the second output topic in case of multip...

apache-kafka-streams spring-cloud-stream

How to create multi output stream from single input stream with Spring Cloud Kafka stream binder?...

spring-boot apache-kafka spring-cloud apache-kafka-streams spring-cloud-stream

Session window how calculate gap?...

apache-kafka apache-kafka-streams

Does this particular Kafka Streams topology introduce a race condition?...

apache-kafka apache-kafka-streams race-condition

Why does Spark application fail with "Exception in thread "main" java.lang.NoClassDef...

java maven apache-spark spark-streaming apache-kafka-streams

Roll back mechanism in kafka processor api?...

apache-kafka apache-kafka-streams

Increase Kafka Streams Consumer Throughput...

spark-streaming kafka-consumer-api apache-kafka-streams spark-streaming-kafka

Kafka streams shuts down if sink node/topic not reachable?...

apache-kafka apache-kafka-streams