apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Debezium: Unable to setup watcher on Kafka-Connect Docker container. Error while fetching metadata with correlation id 2 ... LEADER_NOT_AVAILABLE
user_46303760
•
5
2
1208
debezium apache-kafka docker sql-server
Debezium: No maximum LSN recorded in the database; please ensure that the SQL Server Agent is running
user_46303760
•
3
3
4915
debezium apache-kafka-connect apache-kafka sql-server
Why do I get this compilation error: "could not find implicit value for kstream.Consumed" and how could I fix it?
user_12025060
•
2
3
1281
apache-kafka-streams apache-kafka avro jsonschema scala
Facing NoClassDefFoundError error at Kafka-Spark Structured Streaming integration via PySpark
user_113520770
•
2
2
4260
pyspark-sql spark-structured-streaming pyspark apache-kafka apache-spark
Accessing Kafka broker from outside my LAN
user_43039800
•
3
1
2663
portforwarding apache-kafka networking
Can i do some stateful operations in peek or filter or branch of kafka stream apps?
user_132586030
•
3
2
588
stateful apache-kafka-streams apache-kafka filter
How to do an initial snapshot load with debezium mysql connector kafka?
user_76011810
•
3
1
2385
debezium apache-kafka-connect apache-kafka mysql
Python Kafka consumer with offset management
user_10305420
•
2
2
3895
kafka-consumer-api apache-kafka apache-zookeeper python
Kafka Confluent: delete mode in JDBC sink connector is giving error and not able to use composite key in `pk.fields`
user_108759440
•
2
0
693
apache-kafka-connect apache-kafka
Kafka consumer not consuming messages from secured kafka cluster
user_29568570
•
2
0
932
apache-kafka jaas ssl java
Hot Questions