apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Spring Integration and Kafka: How to filter messages based on message header
user_28151440
•
4
1
7367
spring-integration spring-kafka apache-kafka
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped
user_108536690
•
4
1
3059
debezium apache-kafka database-replication database-administration postgresql
Kafka Spark Structured Streaming with SASL_SSL authentication
user_7411640
•
3
2
7685
spark-kafka-integration spark-structured-streaming apache-kafka apache-spark scala
Kafka console consumer commits wrong offset when using --max-messages
user_129747730
•
2
1
1966
kafka-consumer-api apache-kafka
How can I get kafka schema registry in Pyspark?
user_109779710
•
2
2
183
confluent-schema-registry pyspark apache-kafka apache-spark
Difference between Consumer level offset and Consumer group offset in Kafka
user_95990910
•
2
1
942
kafka-consumer-api apache-kafka
Kafka Streams - Global State Store restoration before stream threads starts processing
user_17686100
•
2
1
534
apache-kafka-streams apache-kafka
kafka disks hault writes during massive reads and cause "queue full" errors in the kafka producer
user_14130660
•
7
1
299
raid sched-deadline spark-streaming apache-kafka
How to use pid as key for log4j2 Kafka appender?
user_25340900
•
2
1
332
log4j2 apache-kafka
Kafka Connect: No tasks created for a connector
user_27328240
•
8
3
3340
confluent-platform apache-kafka-connect apache-kafka
Hot Questions