apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
GCP dataproc - java.lang.NoClassDefFoundError: org/apache/kafka/common/serialization/ByteArraySerializer
user_68431030
•
3
3
1306
google-cloud-dataproc pyspark apache-kafka apache-spark google-cloud-platform
How to monitor size and last update time for Kafka topic
user_125315060
•
2
0
49
apache-kafka java
Java - Is it Possible to Use Spring Cloud Stream Kafka and RabbitMQ for the Same Application
user_45211960
•
1
1
522
spring-rabbit spring-cloud-stream apache-kafka rabbitmq java
Copy messages from one Kafka topic to another using offsets/timestamps
user_103620000
•
1
1
324
apache-kafka
Can Kafka Connect be made rack aware so that my connector reads all partitions from one broker?
user_16030710
•
2
2
294
confluent-platform apache-kafka-connect apache-kafka amazon-web-services amazon-s3
Apache Flink KafkaSource doesnt set group.id
user_71577230
•
1
1
305
flink-streaming apache-flink apache-kafka streaming
Reactive Kafka Receiver and paraller records processing flow
user_180801820
•
2
0
191
reactor-kafka project-reactor apache-kafka
Ksqldb Data Enrichment for nested array
user_127822360
•
2
0
59
ksqldb confluent-platform apache-kafka
Is Transactional ID still required for EOS after KIP-447?
user_7074830
•
1
0
50
apache-kafka
Kafka : ClassCastException: class org.apache.avro.generic.GenericData$Record cannot be cast to class
user_67578140
•
2
1
2429
confluent-schema-registry apache-kafka avro classcastexception java
Hot Questions