apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
How to skip kafka history data in flink job if certain lag is encountered?
user_91723440
•
1
2
131
apache-flink apache-kafka
How to set consumer config values for Kafka Mirrormaker-2 2.6.1?
user_38446830
•
2
0
443
apache-kafka-mirrormaker apache-kafka
How to update Avro schema with a reference to another schema on a Kafka topic?
user_7766830
•
1
1
406
confluent-schema-registry apache-kafka avro
Kafka consumer offset export golang -- sharma or confluent-kafka-go lib
user_10198880
•
1
2
442
apache-kafka go
Kafka Consumer - Point to specific offset in Spring boot Kafka
user_103938560
•
1
1
1217
spring-kafka kafka-consumer-api apache-kafka spring-boot spring
How to properly test kafkaTemplate.send() within a function in Junit5?
user_89981280
•
1
1
284
spring-kafka junit5 apache-kafka integration-testing
Flink job runs to fail on EMR cluster
user_189694480
•
1
1
120
amazon-emr apache-flink apache-kafka java
pyflink with kafka java.lang.RuntimeException: Failed to create stage bundle factory
user_189640740
•
1
1
246
py4j pyflink apache-beam flink-streaming apache-kafka
subsrcibe to many topics in kafka using python
user_189585360
•
1
1
594
apache-kafka python
how to monitor issues with ksql streams in k8s
user_189555770
•
1
0
25
ksqldb apache-kafka
Hot Questions