apache-kafka-streams

apache-kafka-streams

36 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Can we control number of consumers in a consumer group through code in Kafka?
Rajiv Singh0
•
-1
0
14
confluent-platform apache-kafka-streams kafka-consumer-api apache-kafka
Is there any method to verify how many records returned from poll in KStream(Kafka streams) before processing forEach method
subbu kandula0
•
0
1
18
apache-kafka-streams apache-kafka spring-cloud
Join KStream with KTable got No headers available and no default type provided
Jimi0
•
0
0
17
apache-kafka-streams spring-kafka spring-cloud-stream apache-kafka java
Node disconnected errors in Kafka Streams API
subbu kandula0
•
0
1
15
apache-kafka-streams apache-kafka
How Kafka Streams API poll works and how to identify time period where there is no transactions from poll
subbu kandula0
•
0
0
13
apache-kafka-streams apache-kafka
Kaka Stream : Processor API -> InvalidTxnStateException : The producer attemted a transactional operation in an Invalid State
Amol Gawali0
•
0
0
16
apache-kafka-streams apache-kafka
Unable to customize kafkaStreams globalstaterestorelistener
user12380970
•
0
0
13
apache-kafka-streams spring-cloud-stream apache-kafka java
KafkaStream with multiple forwarding for a single input message generates an overweight error
KikeSP0
•
0
0
14
apache-kafka-streams apache-kafka java
timeout of 60000ms expired before the position for partition could be determined
notesdvi0
•
0
0
20
spark-checkpoint spark-streaming apache-kafka-streams spark-structured-streaming apache-spark
Quarkus - KStream and KTable join does not output messages
cogitoergosum0
•
0
1
26
apache-kafka-streams apache-kafka quarkus java
Hot Questions