ich integriere meine anwendung mit spring-kafka (nicht feder-integration-kafka). Hier ist Frühjahr Dokumentation für das Projekt: http://docs.spring.io/spring-kafka/docs/1.0.1.RELEASE/reference/htmlsi
Wir beobachten ein seltsames Verhalten mit unserem Servicetest und Embedded Kafka. Der Test ist ein Spock-Test, wir die JUnit-Regel KafkaEmbedded verwenden und brokersAsString propagieren wie folgt: @
Ich versuche, die spring-kafka KafkaTemplate in einer Spring-Boot-Anwendung zu verwenden, um Nachrichten zu einem Kafka-Thema zu schreiben. ich eine KafkaConfig Klasse erstellt: @Configuration
@Enabl