apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Reset kafka testcontainers without clearing and recreating the testcontainer after every junit test
user_7855230
•
3
1
432
testcontainers apache-kafka junit
Python Faust, how to use take to run on multiple values
user_146993210
•
1
0
212
faust apache-kafka python
How to manually commit kafka offset after FileIO in apache beam?
user_48714740
•
1
1
62
apache-beam-kafkaio apache-beam google-cloud-dataflow apache-kafka
Kafka Producer - Just need some direction
user_179356660
•
1
2
39
apache-kafka jdbc java
Is it a good practice to use the exiting topic for multiple connectors?
user_58286210
•
1
1
75
debezium apache-kafka-connect apache-kafka jdbc postgresql
Elastic Sink Connector not working new version
user_159724980
•
2
1
256
confluent-platform apache-kafka-connect elasticsearch apache-kafka
spring integration kafka listener thread reads multiple partitions when concurrency = partition count
user_28952770
•
2
1
157
spring-integration spring-kafka apache-kafka java
GKE - How to expose pod for cross-cluster communication with MCS
user_87707780
•
1
1
102
redpanda google-kubernetes-engine apache-kafka kubernetes
How to Connect to kafka from python using truststore file?
user_115815340
•
1
1
192
confluent-kafka-python kafka-python apache-kafka python
kafka-stream aggregation on multiple inputs with cogroup and filter
user_61543520
•
1
0
272
spring-kafka apache-kafka-streams spring-cloud-stream apache-kafka java
Hot Questions