Ich bin neu in Kafka Welt. Wir planen, Kafka einzurichten, um unsere Datenstreaminganforderungen zu erfüllen. Die Senke in unserem Fall ist der REST-Endpunkt. Welche Konnektoren sind verfügbar, um Kafka zu unterstützen => REST-Endpunktkonnektivität? Dies ist vergleichbar mit einfachen AWS-Warteschlangen oder -Themen.REST Endpunkt als Kafka Waschbecken
0
A
Antwort
0
AFAIK gibt es keine zertifizierte HTTP-Senke für Apache Kafka. Warum erstellen Sie nicht einfach einen Kafka-Consumer und führen für jede Nachricht (oder Nachrichtenbatch) einen REST-Call zu Ihrem Service durch?
0
Nichts, was mir bekannt ist, aber akka-streams fühlt sich für diesen Anwendungsfall gut an.
die Quelle ein Kafka Nachrichtenstrom wäre erstellt mit akka-stream-kafka (auch bekannt als reaktivem kafka) und die Senkt den akka-HTTP-Client (flow-basierte Variante): http://doc.akka.io/docs/akka-http/10.0.6/scala/http/client-side/request-level.html#flow-based-variant
Integrationsmuster für akka -Ströme werden (beginnend) unter dem Namen alpakka dokumentiert: http://developer.lightbend.com/docs/alpakka/current/
Verwandte Themen
- 1. Avro Records -> Kafka -> Kafka Connect Waschbecken -> Amazon S3 Storage. Idempotenz?
- 2. REST API Endpunkt Namensgebung
- 3. Beispiele für Kafka Rest
- 4. Anylogic - Waschbecken nach DB
- 5. Anfragekörper kommt als Null an REST API-Endpunkt
- 6. ACUMATIC Endpunkt nicht unterstützt REST
- 7. Access Rest api Endpunkt Docker
- 8. Sicherheit Benutzerregistrierung Django Rest Endpunkt
- 9. kafka rest api - Verbindung verweigert
- 10. Confluent Kafka Rest Proxy Autorisierung
- 11. Django REST Swagger: Wie OAuth2/Token-Endpunkt
- 12. mit asp.net mvc für REST-basierte Endpunkt
- 13. Zwei Java-Methoden mit demselben Rest-Endpunkt
- 14. Marklogic benutzerdefinierte Rest-API-Endpunkt Inhaltstyp Problem
- 15. Hit REST-Endpunkt beim Start - Weblogic + ATG
- 16. API Rest Antwortcode für nicht Endpunkt behandeln
- 17. Grundlegender REST-Aufruf an ml.google.com Vorhersage-Endpunkt
- 18. Elasticsearch Bulk-Index api über Rest Endpunkt
- 19. Spring Sicherheit Authentifizierung/Autorisierung über REST Endpunkt
- 20. Derselbe REST-Endpunkt gibt verschiedene Fehlerreaktionsobjekte zurück
- 21. POST von JSON an WCF REST-Endpunkt
- 22. Wie Rest Endpunkt in Scala mit jUnit
- 23. Apache Camel - Spring Rest Endpunkt Referenz
- 24. JsonMappingException beim Zugriff auf den REST-Endpunkt
- 25. LiClipse als potentieller Sicherheitsangriff Endpunkt
- 26. Dynamischer Tabellenname in Cassandra Pojo Waschbecken Fink
- 27. Flink mit Kafka als Quelle
- 28. kafka NoClassDefFoundError kafka/Kafka
- 29. jQuery AJAX gibt begrenzte Ergebnisse vom REST-Endpunkt zurück
- 30. Django - Zugriff auf Django Rest Endpunkt auf AWS Elastic Beanstalk