apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Using kafka-go, how to achieve automatic reconnection after disconnection?
user_160966040
•
2
0
43
apache-kafka go
How to reprocess messages in Kafka Connect?
user_112911910
•
3
1
78
kafka-consumer-api apache-kafka-connect apache-kafka
Can a Kafka consumer scale down to zero?
user_26964860
•
1
3
87
amazon-sqs aws-lambda apache-kafka
KSQL: re-build entity from events
user_35792220
•
2
0
61
ksqldb apache-kafka
Why does `FutureRecord` require me to put the key in an `async` block or specify the type in `rdkafka`?
user_106973580
•
2
1
32
librdkafka apache-kafka rust byte
Kafka headers are being overwritten by Kafka Source
user_191890320
•
1
0
32
cloudevents knative apache-kafka kubernetes
Switching from Broker-side compression to producer compression
user_9917100
•
1
0
28
kafka-producer-api apache-kafka compression
How can I use keystore.jks and truststore.jks files for Kafka Python SSL Authentication after converting to .pem?
user_195063300
•
1
2
280
kafka-python apache-kafka ssl-certificate ssl python
Flink Python Datastream API Kafka Consumer - NoClassDefFoundError ByteArrayDeserializer Error
user_104146370
•
1
1
101
pyflink flink-streaming apache-flink apache-kafka java
Kafka client faced disconnected will reconnect again by again, anyway can disable it?
user_115449600
•
1
1
263
apache-kafka
Hot Questions