apache-kafka-streams

335 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Kafka-streams: setting internal topics cleanup policy to delete doesn't work
user_82472780
•
6
1
2393
apache-kafka-streams apache-kafka
how to compare (1 billion records) data between two kafka streams or Database tables
user_2789380
•
3
1
2257
ksqldb apache-kafka-streams apache-kafka database
Accessing Kafka Stream State Store with Spring
user_59309690
•
3
1
1643
spring-kafka apache-kafka-streams apache-kafka
Why is this KStream/KTable topology propagating records that don't pass the filter?
user_17297950
•
4
1
1132
apache-kafka-streams apache-kafka
Spring Kafka and Kafka Streams
user_12197550
•
4
2
4168
spring-kafka apache-kafka-streams apache-kafka spring-boot java
Why am I occasionally getting a InvalidStateStoreException PARTITIONS_REVOKED, not RUNNING when retrieving a store to query it?
user_17297950
•
3
1
2355
apache-kafka-streams apache-kafka
How change Kafka committed consumer offset with required offset
user_45875960
•
2
1
6232
apache-kafka-streams kafka-consumer-api apache-kafka apache-zookeeper
KTable state store infinite retention
user_56732100
•
8
1
2839
apache-kafka-streams apache-kafka
how to generate id for message when using Kafka stream?
user_22181200
•
3
1
3398
confluent-platform apache-kafka-streams
Is there an equivalent to Kafka's KTable in Apache Flink?
user_26207160
•
4
1
1111
apache-kafka-streams apache-flink
Hot Questions