AvroTypeException: Zeichenfolge gefunden, beim Konsumieren der Kafka-Nachricht wird eine Vereinigung erwartet

Ich richte ein Programm für zyklisch ein, um eine Methode aufzurufen, bei der eine einzelne Nachricht von einer Kaninchennachricht -Warteschlange gelesen wird. Es sollte eine Nachricht verbrauchen...

Ich verwende Spring-Kafka 2.2.2.RELEASE(org.apache.kafka:kafka-clients:jar:2.0.1) und Spring-Boot(2.1.1). Ich kann keine Transaktion ausführen, da mein Listener keine Partition zuweisen kann. Ich...

Hier geht es um den Kafka-Hörer. Wir haben keinen Zugriff auf den Herausgeber (es ist ein Drittanbieter).
Genau 9 Minuten nach dem Start der App erhalten wir Folgendes in unseren...

Mein Kafka -Produzent erstellt Nachrichten mit etwa .. 350 MB pro 30 Sekunden ..

Kafka Setup :

--> 1 Zookeeper instance

--> 3 Kafka Brokers

--> 1 Java Producer

--> 1 Java Verbraucher

So...

Ich arbeite derzeit an einem Projekt mit Java Spring Boot und Apache Kafka, bei dem mehrere Microservices über Kafka kommunizieren. Unser Ziel ist es, 100.000 Transaktionen pro Sekunde (TPS) (oder...