apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Kafka returns "No matching PRIVATE KEY entries in PEM file" when attempting to start using PEM certificates
user_31956880
•
2
2
1593
apache-kafka pem ssl
Is there way to map RabbitMQ routing key in Kafka connnector configurations for registering RabbitMQSourceConnector?
user_70637190
•
2
0
164
strimzi confluent-platform apache-kafka-connect apache-kafka rabbitmq
Rebalance in progress exception occurs unpredicatably
user_89903290
•
1
0
194
rebalancing apache-kafka exception java
What is the format of `camel.sink.endpoint.connectionFactory` (for Camel Bigquery Kafka Sink Connector)?
user_81756590
•
1
0
73
apache-kafka google-bigquery apache-camel
Questions for reading data from JDBC source in DataStream Flink
user_166326180
•
2
1
1046
flink-streaming apache-flink apache-kafka jdbc java
When is offset committed in KafkaListener.java in Springboot?
user_33009110
•
2
1
789
spring-kafka kafka-consumer-api apache-kafka java
Apache Flink using Java - Performance Issue
user_166173270
•
2
1
223
flink-streaming apache-flink apache-kafka java
Confluent Kafka S3 sink connector throws `java.lang.NoClassDefFoundError: com/google/common/base/Preconditions` when using Parquet format
user_9020360
•
2
1
545
s3-kafka-connector apache-kafka-connect apache-kafka
Kafka consumer not picking mentioned Bootstrap servers
user_42427650
•
2
1
1460
spring-kafka apache-kafka spring-boot
Change topic name used by Debezium connector
user_166069020
•
2
1
1111
debezium apache-kafka-connect apache-kafka
Hot Questions