Ich möchte Federunterstützung verwenden, um mit Kafka zu integrieren. Die Server-Version ist 0.8.2.2, aber alle Frühlings-Projekte, die ich finden konnte, verwenden neuere Kafka. sogar spring-kafka-1.0.0 verwendet kafka 0.9.0.1. und ich habe gelesen, dass der Kafka-Client nicht abwärtskompatibel ist. Die Frage ist also: Gibt es eine Frühjahrsunterstützung für ältere Kafka-Version oder muss ich einen offiziellen Kafka-Client bekommen und mache es alleine?Gibt es eine Federunterstützung für Kafka 0.8.2.2?
0
A
Antwort
3
Spring Cloud Stream 1.0.x
Versionen unterstützt Kafka-Binder mit Kafka-Version 0.8.2.2
. Spring Integration Kafka 1.3.x
Version verwendet auch Kafka 0.8.2.2
.
0
Sie können feder Integration 1.3.x mit Feder-Integration-kafka verwenden und die Feder-Integration-java-dsl mit Kafka zu integrieren 0.8.2.2
Z.B. Wenn Sie maven verwenden:
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-java-dsl</artifactId>
<version>1.1.2.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-kafka</artifactId>
<version>1.3.0.RELEASE</version>
</dependency>
Wenn Sie die High-Level-API verwenden, wird dies ziemlich gut für Sie arbeiten. Wenn Sie Low-Level-Unterstützung benötigen, um Ihre eigenen Partitionszeiger und Leader-Wahlen zu verwalten, wird es etwas schwieriger sein, Dokumentation zu diesen Teilen zu finden.
Verwandte Themen
- 1. Gibt es eine CloudFormation Vorlage für DC/OS, ElasticSearch, Kafka Connect und Kafka Streams?
- 2. Verwenden Sie eine andere Version von kafka - 0.8.2.2 und 0.10.1 API in der gleichen Anwendung
- 3. Welche Einschränkungen gibt es bei Apache Kafka?
- 4. Apache Nifi Benutzerdefinierte Prozessoren mit Federunterstützung
- 5. Gibt es eine Möglichkeit, Offset für jede Nachricht in Kafka-Streams zu erhalten?
- 6. Gibt es eine Möglichkeit, unbegrenzte Wiederholungen für benutzerdefinierte Kafka Deserializer zu stoppen?
- 7. Kafka Zookeeper Verbindung gibt
- 8. Kafka gibt NoSuchElementException
- 9. Frühling Kafka-Integration für Kafka 0.9
- 10. Wie viele Daten gibt es in welcher Partition in Kafka?
- 11. Kafka-Stream gibt seltsame Ausgabe
- 12. Gibt es eine Kodierungskonvention für eine "Zeilenregel" für Java?
- 13. PDFlib für PHP, gibt es eine Alternative
- 14. Gibt es ein Klickverhalten für eine Liste?
- 15. Gibt es eine AES-Bibliothek für Clojure?
- 16. Gibt es eine Hash-Funktion für Datumsangaben?
- 17. Gibt es eine Schnittstelle für System.IO.Stream?
- 18. Gibt es eine Erlang-Implementierung für Android?
- 19. Gibt es eine ideale Größe für Hintergrundbilder?
- 20. Gibt es eine Größenbeschränkung für Pandas read_table()?
- 21. Gibt es eine Vibrations-API für UWP?
- 22. Gibt es eine umgekehrte Methode für .charAt()?
- 23. Gibt es eine eindeutige ID für Modifikatoren?
- 24. Gibt es eine Namenskonvention für Git-Repositories?
- 25. Gibt es eine Bayes'sche Filterbibliothek für .NET?
- 26. Gibt es eine Baumkontrolle für das iPhone?
- 27. MySQL Gibt es eine Grenze für InnerJoin?
- 28. Gibt es eine Standarddarstellung für HTML-Formulare?
- 29. Gibt es eine Handschrifterkennungsbibliothek für IOS?
- 30. Gibt es eine gute Diagrammbibliothek für Python?
danke. Frühlingsintegration '1.3.x' verwendet' 0.8.2.1', aber AFAIK ist sicher zu stoßen: https://github.com/spring-projects/spring-integration-kafka/tree/v1.3.0.RELEASE, aber ich kann keine finden Informationen über Versionen in spring-cloud-stream docs: http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/ könnten Sie einen Link bereitstellen? – piotrek
Ich sehe es nicht explizit in dieser Dokumentation angegeben, da ich denke, dass wir zu dieser Zeit nur Unterstützung für 0.8.x.x hatten. Sie können die Version trotzdem hier sehen: https://github.com/spring-cloud/spring-cloud-stream/blob/1.0.x/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/ pom.xml # L17 –