apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How to use kafka.group.id and checkpoints in spark 3.0 structured streaming to continue to read from Kafka where it left off after restart?
user_117420300
•
5
1
2892
spark-kafka-integration spark-structured-streaming apache-kafka apache-spark scala
Sarama Kafka library: how to unit test a consumer group's session.MarkMessage()?
user_9958620
•
2
0
1665
sarama apache-kafka go
What are benefits of using more than 1 partition in Kafka?
user_143169750
•
2
2
857
kafka-producer-api apache-kafka
REST WSO2 Kafka
user_142876220
•
2
2
194
wso2-esb apache-kafka wso2
WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Bootstrap broker 127.0.0.1:9092 (id: -1 rack: null) disconnected
user_91517440
•
3
1
11339
producer apache-kafka maven java
Size of Kafka Partitions and writing to a Topic with no free disk space
user_70416980
•
2
1
812
kafka-topic kafka-partition apache-kafka
poll() and commitAsync() in Spring-Kafka
user_9827470
•
3
2
1343
spring-kafka apache-kafka spring-boot
Can a kafka consumer group freeze during a rebalance
user_61831820
•
5
1
993
kafka-consumer-api apache-kafka
Does Kafka work with load balancers using reverse proxies?
user_2319340
•
2
1
786
apache-kafka load-balancing
Does Spark Structured Streaming have some timeout issue when reading streams from a Kafka topic?
user_117420300
•
2
1
658
spark-streaming-kafka spark-structured-streaming apache-kafka apache-spark
Hot Questions