apache-kafka-streams

335 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Does deleting a record from Kafka state store deletes the record from changelog topic as well?
user_40315200
•
2
2
1237
apache-kafka-streams tombstone apache-kafka aggregation
How I receive the last windowed Kafka message in a windowedBy+aggregate when producer stops to send messages in Java/Spring?
user_141767360
•
2
1
281
apache-kafka-streams kafka-consumer-api apache-kafka spring java
Can we use any other database like MariaDB or MongoDB for Storing states in Kafka Streams instead of Rocks DB, is there any way to configure it?
user_127091280
•
4
1
538
apache-kafka-streams spring-cloud-stream apache-kafka mongodb
kafka-streams alert on kafka connection faliure
user_40390140
•
5
1
1159
apache-kafka-streams kafka-consumer-api apache-kafka
Can we Convert KStream to Global KTable in Apache Kafka?
user_129536770
•
2
1
1734
confluent-platform apache-kafka-streams apache-kafka scala
KGroupedStream with cogroup, aggregate & suppress
user_95667210
•
2
0
453
apache-kafka-streams apache-kafka
How to merge two kafka topics data when second topic data arrives late
user_39789860
•
2
1
715
apache-kafka-streams apache-kafka
Kafka Streams - Unpredictable result of aggregation
user_27256030
•
2
1
35
apache-kafka-streams
How to lookup dynamically in a KTable?
user_14625250
•
2
1
237
apache-kafka-streams apache-kafka
Using Custom Kafka State Stores in kstreams application
user_36055640
•
3
1
1424
apache-kafka-streams spring-cloud-stream-binder-kafka spring-cloud-stream apache-kafka java
Hot Questions