apache-kafka

13Hitze

2Antwort

Fehler: Die Hauptklasse konnte nicht gefunden oder geladen werden. Config.zookeke.properties

Ich versuche, eine Beispiel-Producer-Consumer-Anwendung mit Apache Kafka auszuführen. Ich habe es von https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz heruntergeladen.

3Hitze

1Antwort

Wie kann ich Daten von MySQL zum Kafka-Produzenten bringen?

Ich bin ein frischer in Big Data. Ich habe eine Datenbank in MySQL und ich weiß nicht, wie man dies in Apache Kafka für den Streaming-Prozess importiert. Und dann erhalten Daten vom Verbraucher. Bitte

1Hitze

1Antwort

Nicht Kafka Zuhörer von Java-Client api zu sichern verbinden können

diese Fehler während Kafka auf SSL verbindet: gescheitert Führer zu finden Sets ([Test, 0]) kafka.common.BrokerEndPointNotAvailableException: Endpunkt mit Sicherheitsprotokoll KLARTEXT nicht für Makle

1Hitze

1Antwort

Was ist der Unterschied zwischen einem "Kafka Spout" und einem "Kafka Consumer"?

sowohl "Kafka Spout" als auch "Kafka Consumer" rufen Daten von den Kafka Brokern ab, der Auslauf, den ich kenne, dient der Kommunikation mit Storm, und der Konsument ist mit was auch immer. -aber imme

3Hitze

2Antwort

Spark Streaming von Kafka Consumer

Ich muss vielleicht mit Kafka arbeiten und ich bin absolut neu dazu. Ich verstehe, dass es einen Kafka-Produzenten gibt, der die Protokolle von Kafka-Themen bekommt. Ich werde arbeiten, um von Kafka T

0Hitze

1Antwort

Kafka-Knoten im Knoten fetchMaxBytes Parameter

Weiß jemand, was 2 Parameter in der FetchMaxBytes darstellen? Wenn es als 1024 * 1024 dargestellt wird, bedeutet das, dass der Kunde 1024 Nachrichten von jedem 1Kb abrufen wird? Oder wird es Spaß mach

0Hitze

1Antwort

Consumer Commit Offsets, aber nicht durch/v2/kafka/(Cluster)/Consumer

Ich habe eine Baugrube installieren und zeigte auf meinen Kafka-Server. (1 Broker und 1 Tierpfleger) .Wenn ich anrufe/v2/kafka/kafka1/consumer, ich bekomme die Antwort, keine Verbraucher. d.h {"error"

3Hitze

2Antwort

Kafka nicht committed Nachrichten

Lässt sagen, die Partition hat 4 Replikate (1 Führer, 3 Anhänger) und alle sind derzeit synchron. min.insync.replicas ist auf 3 eingestellt und request.required.acks ist auf all oder -1 eingestellt. D

0Hitze

1Antwort

Spark Streaming - Java - JSON von Kafka in Cassandra einfügen

Ich schreibe eine einfache Datenpipeline in Spark Streaming mit Java, um JSON-Daten aus Kafka zu ziehen, analysiere den JSON in eine benutzerdefinierte Klasse (Transaction) und füge dann diesen ein Da

0Hitze

1Antwort

MQ Wahl für Punkt-zu-Punkt-Hochdurchsatz-

Ich habe ein Szenario mit diesen besonderen Anforderungen: Produktion bereit & stabil. Punkt-zu-Punkt-Verbindung, mit dem Hersteller hinter einer Firewall und einem Verbraucher in der Cloud. Es könnte