/ / Frühling Kafka mit TCP Port als Produzent - Java, Frühling, TCP, Apache-Kafka, Kafka-Produzent-API

Frühling Kafka mit TCP Port als Produzent - Java, Frühling, TCP, Apache-Kafka, Kafka-Produzent-API

Ich bin neu bei Kafka und Streaming, also ertragen Sie mit mir.

Ich habe sowohl den Tierpfleger als auch den Tierpfleger installiert und gestartetKafka erfolgreich. Es wurde ein einfaches Thema erstellt und der Konsolenbenutzer gestartet, der in der Konsole gehört und anzeigt, was an dieses Thema gesendet wird. Der Produzent sendet derzeit Informationen als Ergebnis des Endpunktanrufs.

Ich habe ein Gerät, das gesendet wird NMEA Formatiere Daten an einen TCP-Port. Wie kann ich einen TCP-Port als Kafka Producer verfügbar machen?

Wenn jemand zusätzliche Informationen benötigt, zögern Sie nicht zu fragen.

Antworten:

1 für die Antwort № 1

Sie müssen eine Anwendung schreiben, die den TCP-Port abhört, die Daten in das gewünschte Format dekodiert und dann an a KafkaProducer um es in das Thema zu schreiben.

Verwandte Fragen

Was würde Kafka tun, wenn der Produzent untergeht? - Twitter, Apache-Kafka, Twitter-Streaming-API
Spring Integration - ActiveMQ nach Kafka - Frühling, Apache-Kafka, Frühjahrsintegration, activemq, Spring-dsl
Wie man den Kundenservice für kafka als kontinuierlichen Zuhörer entlarvt - spring, cxf, spring-integration, apache-kafka, kafka-consumer-api
Frühlings-Wolken-Bus - Frühlingswolke
Spring Cloud DataFlow und Kafka Security - Spring-Cloud-Stream, Spring-Cloud-Datenfluss
KafkaProducerException beim Senden einer Nachricht an ein Thema - Spring-Boot, Apache-Kafka, Kafka-Produzent-API, Frühling-Kafka
kafka-node, Wie hält man die Verbindung von Nodejs aufrecht, wenn der Broker nicht aktiv ist? - node.js, apache-kafka
KafkaProducer sendet keinen Datensatz - java, apache-kafka, kafka-producer-api
spring-cloud-starter-stream-kafka erstellt kein Thema für spring.boot.cloud.stream.bindings.output.destination - java, docker, feder-boot, apache-kafka, docker-compose
Erstellen eines neuen Kafka Producer-Objekts für jede Anfrage - Java, Apache-Kafka, Nachrichten-Warteschlange
Wie kann ich IOException behandeln, wenn Kafka nicht verfügbar ist? - Java, Ausnahme, verbinden, Apache-Kafka
Kafka Producer Behaviour - Apache-Kafka, Kafka-Produzent-Api
Kafka-Konsolenproduzent, der nicht erlaubt, Nachricht zu schreiben - Apache-kafka, kafka-Erzeuger-api
Wo ist der Kafka Bulk Producer API - Apache-Kafka
Die Bedeutung von 'request.timeout.ms' des Kafka-Produzenten macht mich verwirrt - Apache-Kafka, Kafka-Produzent-Api
Kafka API Encoder vs Serializer - Apache-Kafka, Kafka-Verbraucher-API, Kafka-Produzent-API
Hat Kafka eine Obergrenze für die Anzahl der Verbraucher, die es unterstützen kann? - Apache-Kafka, Kafka-Verbraucher-API, Kafka-Produzent-API
Start Stream vor Produzent in Kafka - Apache-Kafka, Apache-Kafka-Streams
Wie benachrichtigt man einen Produzenten in kafka? - Apache-Kafka
wie man kafka server programmatisch startet - apache-kafka, spring-kafka