apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Can kafka partitions be spread across multiple kafka cluster nodes?
user_78719990
•
2
2
1185
kafka-cluster confluent-platform apache-kafka spring-boot java
Produce called with an IAsyncSerializer value serializer configured but an ISerializer is required when using Avro Serializer
user_3673190
•
2
1
866
confluent-schema-registry confluent-platform apache-kafka avro
write pyspark dataframe to kafka
user_72554390
•
2
1
126
pyspark apache-kafka
Kafka: what is the point of using "acknowledgment.nack" if I can simply "not acknowledgment.acknowledge"
user_41481750
•
8
1
9841
spring-integration spring-kafka kafka-consumer-api apache-kafka java
BufferError: Local: Queue full in Python
user_50034900
•
8
1
5213
apache-kafka python
Getting store for GlobalKTable crashes after upgrading to kafka-streams:5.5.0-css (Apache Kafka 2.5.0) [RESOLVED]
user_128761200
•
2
1
790
spring-kafka apache-kafka-streams apache-kafka spring java
Kafka Stream KTable-KTable keyed join producing duplicate events(Detected out-of-order KTable)
user_25874300
•
2
1
2386
apache-kafka-streams apache-kafka java
Embedded Kafka tests randomly failing
user_12583190
•
3
1
3543
spring-kafka-test spring-kafka apache-kafka
How to use Kafka Transactional Producer with Schema Registry with multiple Schema Records?
user_3673190
•
2
1
213
confluent-platform apache-kafka .net
Spark from_avro() dataframe.show() errors java.lang.ArrayIndexOutOfBoundsException
user_108676870
•
5
1
619
spark-avro apache-kafka avro apache-spark scala
Hot Questions