apache-kafka-streams

335 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Merge Kafka record Values from single stream
user_55675280
•
1
1
136
spring-kafka apache-kafka-streams java
In kafka stream topology with 'exactly_once' processing guarantee, message lost on exception
user_61878300
•
1
0
368
exactly-once topology apache-kafka-streams java
Getting "java.lang.IllegalStateException: Tried to lookup lag for unknown task 3_0" after upgrading Kafka Stream from 2.5.1 to 2.6.2
user_159340210
•
7
1
2714
apache-kafka-streams apache-kafka
StreamsException: Unable to initialize state, this can happen if multiple instances of Kafka Streams are running in the same state directory
user_41894190
•
3
6
3312
spring-kafka apache-kafka-streams java-8 spring-boot
kafka streams example throws a class cast exception, serde windowed -> string. How to set the proper Serde?
user_3560110
•
1
1
632
apache-kafka-streams apache-kafka java
Kafka Streams Binding: Cannot get state store because the stream thread is PARTITIONS_ASSIGNED, not RUNNING
user_91288630
•
2
1
1531
apache-kafka-streams spring-cloud-stream apache-kafka
what is the difference between stateful and stateless transformation in Kstreams?
user_31227710
•
2
2
765
apache-kafka-streams apache-kafka
Dynamically changing the instanceindex with spring cloud stream kafka
user_105849960
•
5
1
262
spring-batch-stream spring-kafka apache-kafka-streams apache-kafka spring-boot
Kafka streams throwing InvalidProducerException frequently
user_51224050
•
2
0
365
apache-kafka-streams apache-kafka
TestContainers Kafka cleanup
user_3290820
•
2
1
550
testcontainers apache-kafka-streams apache-kafka java
Hot Questions