apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
flink Pipeline not processing Kafka messages after switching source
user_169131050
•
1
0
91
apache-beam-io apache-beam apache-flink apache-kafka
Kafka Broker Failed authentication - SSL handshake failed
user_21280140
•
2
1
2056
apache-kafka ssl
Retry max 3 times when consuming batches in Spring Cloud Stream Kafka Binder
user_118176720
•
1
1
1413
spring-cloud-stream-binder-kafka spring-cloud-stream apache-kafka spring java
Kafka Unit Testing Transaction with MockProducer and MockConsumer
user_3375460
•
2
0
219
kafka-consumer-api apache-kafka unit-testing java
How is spark.streaming.kafka.maxRatePerPartition related to spark.streaming.backpressure.enabled incase of spark streaming with Kafka?
user_71195010
•
4
1
816
spark-streaming spark-structured-streaming pyspark apache-kafka apache-spark
Kafka Sticky Partitioner using spring cloud stream
user_21438460
•
3
1
178
spring-cloud-stream apache-kafka
spring kafka stream consume messages from multiple topics using functional style not working
user_39452380
•
2
1
467
spring-kafka spring-cloud-stream apache-kafka
Bulk processing data through a join with kafka-streams results in `Skipping record for expired segment`
Matt_Sheppard_7970
•
5
1
579
apache-kafka-streams apache-kafka java
Read from topic and write the messages in batches to a REST endpoint using reactor Kafka
user_39853320
•
2
1
344
reactor-kafka project-reactor spring-kafka apache-kafka spring-webflux
Is it possible to read from a python websocket and write to kafka topic?
user_141712070
•
2
0
355
producer apache-kafka websocket python
Hot Questions