StackOverflow Questions for Tag: kafka-streams-scala

fafl

Reputation: 7385

Kafka Streams with state store and Forward compatibility

apache-kafkaapache-kafka-streamsconfluent-schema-registry

Score: 0

Answers: 1

Yoni Weisberg

Reputation: 1

In Kafka Streams KGroupedTable.aggregate, should the adder and subtractor return a new immutable aggregator on every call?

javaapache-kafkaapache-kafka-streams

Score: 0

Answers: 1

Utkarsh Sharma

Reputation: 51

Retention period with global K tables in kafka streams

apache-kafka-streamsktable

Score: 0

Answers: 1

Anas Ahmad

Reputation: 21

KStreams KTbale left join is not working for all records

apache-kafka-streamsktable

Score: 2

Answers: 1

Victoriia

Reputation: 119

More than one tumbling window

apache-kafka-streams

Score: 0

Answers: 1

mohammadjavadkh

Reputation: 70

access to window start time in aggregation function

spring-bootapache-kafkaapache-kafka-streams

Score: 0

Answers: 1

Misa

Reputation: 43

How to Access Headers in a GlobalKTable in Kafka Streams

javaspring-bootapache-kafkaspring-kafkaapache-kafka-streams

Score: 0

Answers: 1

xmm_581

Reputation: 41

Kafka Streams send custom headers with Transformer when multiple messages output

javaapache-kafkaapache-kafka-streams

Score: 0

Answers: 1

suno3

Reputation: 171

Kafka Streams: NPE in ProcessorRecordContext and Suppress issues with processValues()

apache-kafka-streamssuppress

Score: 3

Answers: 1

Ashutosh Singh

Reputation: 1

Kafka Streams Window Size (15 mins) is greater than the max poll interval (5 min)

apache-kafkaspring-kafkaapache-kafka-streams

Score: 0

Answers: 1

bm1729

Reputation: 2375

Handling bad messages using Kafka's Streams API

error-handlingapache-kafkaapache-kafka-streams

Score: 49

Answers: 7

John Ament

Reputation: 11723

Seeing duplicate records created in a streams app's output

apache-kafkaapache-kafka-streamsapache-kafka-connectapache-iceberg

Score: 1

Answers: 1

simonC

Reputation: 4327

kafka stream global store returns null on key that was inserted

apache-kafkaapache-kafka-streams

Score: 0

Answers: 1

sabtharishi

Reputation: 3291

Kafka: Consumer API vs Streams API

apache-kafkakafka-consumer-apiapache-kafka-streams

Score: 182

Answers: 3

birinder tiwana

Reputation: 83

Java virtual threads and kafka streams

javamultithreadingscaleapache-kafka-streamsvirtual-threads

Score: 4

Answers: 0

M. Bouzaien

Reputation: 1

kafka-streams does not add the right kafka-clients dependency

javamavenapache-kafkaapache-kafka-streams

Score: 0

Answers: 0

Paul Marcelin Bejan

Reputation: 1675

Kafka Streams state store vs MongoDB for state management

mongodbapache-kafkaarchitectureapache-kafka-streams

Score: 0

Answers: 1

sundararajan s

Reputation: 1

TraceId not printing in kafka-stream application

javaspring-bootapache-kafkaspring-kafkaapache-kafka-streams

Score: 0

Answers: 0

erankl

Reputation: 316

Suppress triggers events only when new events are received on the stream

apache-kafka-streams

Score: 6

Answers: 2

Egor

Reputation: 1660

App producing 2 messages for only 1 input

apache-kafkaapache-kafka-streamsreduce

Score: 0

Answers: 1

PreviousPage 2Next

StackOverflow Questions for Tag: kafka-streams-scala

Kafka Streams with state store and Forward compatibility

In Kafka Streams KGroupedTable.aggregate, should the adder and subtractor return a new immutable aggregator on every call?

Retention period with global K tables in kafka streams

KStreams KTbale left join is not working for all records

More than one tumbling window

access to window start time in aggregation function

How to Access Headers in a GlobalKTable in Kafka Streams

Kafka Streams send custom headers with Transformer when multiple messages output

Kafka Streams: NPE in ProcessorRecordContext and Suppress issues with processValues()

Kafka Streams Window Size (15 mins) is greater than the max poll interval (5 min)

Handling bad messages using Kafka&#39;s Streams API

Seeing duplicate records created in a streams app&#39;s output

kafka stream global store returns null on key that was inserted

Kafka: Consumer API vs Streams API

Java virtual threads and kafka streams

kafka-streams does not add the right kafka-clients dependency

Kafka Streams state store vs MongoDB for state management

TraceId not printing in kafka-stream application

Suppress triggers events only when new events are received on the stream

App producing 2 messages for only 1 input

Handling bad messages using Kafka's Streams API

Seeing duplicate records created in a streams app's output