apache-kafka-streams

335 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How to eval code that uses InterfaceStability annotation (that fails with "illegal cyclic reference involving class InterfaceStability")?
user_14652190
•
3
1
254
apache-kafka-streams apache-kafka reflection scala
How to output result of windowed aggregation only when window is finished?
user_10287410
•
8
1
1482
apache-kafka-streams apache-kafka
Kafka Streams - SerializationException: Unknown magic byte
user_107602660
•
11
1
28952
confluent-schema-registry apache-kafka-streams apache-kafka avro java
After kafka crashed, the offsets are lost
user_58718630
•
3
1
1283
spring-kafka apache-kafka-streams kafka-consumer-api apache-kafka java
When to use GlobalKTable over KTable when 1 partition is used
user_62218280
•
5
1
1831
kafka-streams-scala apache-kafka-streams
RocksDB in Kafka stream reporting no space when there is space available
user_616730
•
2
1
1299
rocksdb apache-kafka-streams apache-kafka
KafkaStreams How to specify Serdes in stream aggregation?
user_41942890
•
6
1
6167
apache-kafka-streams apache-kafka java
Join on foreign key in Kafka stream
user_19171230
•
8
2
4835
apache-kafka-streams apache-kafka
Is there anyway to use different auto.offset.reset strategy for different input topics in kafka streams app?
user_18282600
•
2
1
396
apache-kafka-streams apache-kafka
Kafka Streams - reusing streams using through() vs toStream() + to()
user_105941540
•
4
1
2228
apache-kafka-streams apache-kafka
Hot Questions