Was ist die sauberere und effizientere Möglichkeit, den Gesundheitscheck für Kafka in meiner Spring-Boot-Anwendung zu im

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...

Ich habe eine einfache geplante Aufgabe:
@Component
public class ScheduledTasks {

@Scheduled
public void doSomething() {
..
}
}

Von dort werden Ausnahmen an SpringbootApplication.java propagiert....

Ich arbeite an einem Problem, bei dem ich eine rekursive Lösung implementiert habe, die den linken und rechten Subtree auf spiegelende Weise vergleicht. Es funktioniert tatsächlich für meine...

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...