apache-kafka

0Hitze

2Antwort

Howto konfigurieren kafkaConnect von kafka zu cassandra

ich einrichten möchten verbinden die kafka von kafka Thema cassandra Das Problem ist einfach: sagen, dass ich wie ein Demo-Thema in kafka mit json Daten {"id":"1", "name":"Alex", "clicks":2} Ich möc

0Hitze

1Antwort

Nicht zu Kafka Broker zu produzieren java.nio.BufferUnderflowException

Ich bin in der Lage, Nachrichten von der kafka-console-producer.sh zu produzieren, aber der Java-Client ist nicht in der Lage, mit der unten genannten Ausnahme zu produzieren. mit Java 7, Kafka Versio

2Hitze

1Antwort

Kafka - wie man nach neuen Nachrichten sucht

Ich habe PHP-Anwendung, die Kafka-Nachrichten verbraucht. Das Problem ist, wie man weiß, dass es neue Nachrichten in Kafka gibt? Die erste Lösung besteht darin, einen Benutzer in PHP zu erstellen und

1Hitze

2Antwort

Hadoop OutputFormat RunTimeException beim Ausführen von Apache Spark Kafka Stream

Ich verwende ein Programm, das Apache Spark verwendet, um Daten vom Apache Kafka-Cluster abzurufen und die Daten in eine Hadoop-Datei zu stellen. Mein Programm ist unter: public final class SparkKafka

0Hitze

1Antwort

Kafka MirrorMaker Replikation zwischen mehreren Regionen

HINWEIS: Auch an [email protected] Ich brauche eine Lösung, die ein Thema an einem Remote-Standort spiegelt, die Zyklen und ein Thema pro Region Problem vermeidet. Diese Lösung würde GENAU zwei Themen

0Hitze

1Antwort

Problem beim Einrichten von Kafka-Umgebung

Momentan habe ich ein Problem bei der Installation und Konfiguration einer Kafka-Umgebung. Es gibt kein Problem beim Herunterladen von zookeeper, und der Server funktioniert einwandfrei. Leider ist de

0Hitze

1Antwort

Scala - Tweets abonnieren - Kafka Topic und Ingest in HBase

Ich muss Tweets aus einem Kafka Topic konsumieren und gleich in HBase aufnehmen. Das Folgende ist der Code, den ich geschrieben habe, aber das funktioniert nicht richtig. Der Hauptcode ruft nicht die

8Hitze

2Antwort

Kafka und Firewall Regeln

Wir haben eine ziemlich strenge Netzwerksegmentierungspolitik. Ich verwende eine Cloud Foundry-Instanz, um eine App zu implementieren. Die Firewall-Regeln wurden so eingerichtet, dass sie den Kafka-Cl

1Hitze

2Antwort

Kafka Cluster Security für IOT

Ich bin neu im Kafka und möchte Kafka Production Cluster für IOT einsetzen. Wir werden über das Internet Nachrichten von Raspberry Pi an unseren Kafka-Cluster erhalten, den wir auf AWS hosten werden.

3Hitze

2Antwort

Durchsatz für Kafka, Spark, Elasticsearch Stack unter GCP/Dataproc

Ich arbeite an einem Forschungsprojekt, bei dem ich eine komplette Datenanalyse-Pipeline auf der Google Cloud Platform installiert habe. Wir schätzen eindeutige Besucher pro URL in Echtzeit mithilfe v