apache-kafka-streams Examples and Free Source Code

A Kafka Stream contains List<Employee>, I want to create a unpacked output stream with Employe...

java apache-kafka apache-kafka-streams

Akka Stream Kafka vs Kafka Streams...

scala akka-stream apache-kafka-streams typesafe stream-processing

How can I set default-key/value-serde in application.properties - Spring Boot Kafka Streams...

java spring-boot apache-kafka apache-kafka-streams spring-kafka

MessageAndMetadata cannot be resolved to a type...

apache-spark apache-kafka apache-kafka-streams message

Kafka Streaming Concurrency?...

apache-kafka apache-kafka-streams

How to use Kafka Streams to only process messages sent less than 3 times per key (UserId) over a giv...

java apache-kafka apache-kafka-streams kafka-join

Define KSQL STRUCT on JSON valued topic with different types...

apache-kafka apache-kafka-streams ksqldb

Counting kafka messages with same key value using kafka streams...

java apache-kafka apache-kafka-streams

Can I have/build a "null topology" with Kafka Streams?...

apache-kafka apache-kafka-streams

Kafka Streams 2.5.0 requires input topic...

apache-kafka apache-kafka-streams

The "first offset" of a topic that backs a ksqlDB stream is always equal to the topic'...

apache-kafka apache-kafka-streams ksqldb

Strategies to migrate stateful stream (KTable) and materialized views in Kafka...

apache-kafka apache-kafka-streams

In Kafka Streams Application the second output stream is not written anymore...

apache-kafka apache-kafka-streams

Documents not getting deleted in kafka streams...

apache-kafka apache-kafka-streams

Kafka Streams Scala Memory Leak...

scala apache-kafka memory-leaks apache-kafka-streams

How to read data from Kafka Topic with Stream...

apache-kafka apache-kafka-streams apache-kafka-connect ksqldb

How to change a value in a field in an Avro object with Kafka Streams application...

java apache-kafka apache-kafka-streams avro

Kafka Streams Avro Consumer is not able to retrieve Avro schema for id 10007...

apache-kafka apache-kafka-streams avro confluent-schema-registry confluent-cloud

Spring cloud kafka stream consumer retry mechanism...

spring-boot spring-cloud kafka-consumer-api apache-kafka-streams

How to push selective fields from the key and value from Topic1 to Topic2 using kafka streams...

apache-kafka apache-kafka-streams

How to get the ConsumerRecord object in StreamListener Consumer code...

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

Error deserializing Avro message - java.nio.HeapByteBuffer cannot be cast to class java.math.BigDeci...

java apache-kafka-streams avro

How to solve InvalidTopicException with multiplexed input topics in Spring Cloud Stream Kafka Stream...

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

Kafka Partitioner using value instead of key...

java apache-kafka apache-kafka-streams

kafka streams doesn't start up...

docker apache-kafka apache-kafka-streams

How to configure a custom Kafka deserializer and get the consumed JSON data using a KafkaListener...

spring spring-boot apache-kafka apache-kafka-streams spring-kafka

How do I consume Kafka-Messages older than x minutes, but all messages on restart?...

apache-kafka apache-kafka-streams

Can I use a spring cloud stream function definition for multiple tenants (kafka binder)?...

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

Problem creating tests with Spring cloud streams kafka streams using embeddedKafka with MockSchemaRe...

java apache-kafka-streams spring-cloud-stream confluent-schema-registry embedded-kafka

Is there a way to repartition the input topic in Kafka streams?...

apache-kafka apache-kafka-streams