apache-kafka

5Hitze

2Antwort

Wie man Kafka Cluster Fehler behandelt

Wir werden ein Kafka Publish Subscribe System implementieren. Jetzt, in den schlimmsten der schlimmsten Fälle - wenn alle Kafka Broker für ein bestimmtes Thema untergehen - was passiert? Ich habe dies

apache-kafka kafka-consumer-api 2016-03-03

---

6Hitze

1Antwort

wie kafka acls verwenden?

Meine Version von Kafka ist 0.9.0.1 und ich habe zwei Broker: 192.168.1.100, 192.168.1.101, die SSL verwenden, um zu authentifizieren und zu verschlüsseln. erhalten bin/kafka-acls.sh --authorizer-prop

apache-kafka acl 2016-03-03

---

67Hitze

13Antwort

Leader Nicht verfügbar Kafka in Console Producer

Ich versuche Kafka zu verwenden. Alle Konfigurationen sind richtig gemacht, aber wenn ich versuche, Nachricht zu erzeugen, von der Konsole Ich erhalte Fehler folgende WARN Error while fetching metadat

apache-kafka producer 2016-03-04

---

26Hitze

4Antwort

Kafka in Docker funktioniert nicht

Ich versuche wurstmeister\kafka-docker Bild mit docker-compose zu verwenden, aber ich habe echte Probleme mit der Verbindung alles. Alle Beiträge oder Fragen, die ich überprüfe, scheint keine Probleme

docker apache-kafka docker-compose kafka-python 2016-03-08

---

6Hitze

2Antwort

kafka upgrade auf .9 mit neuer consumer api

Wir aktualisieren unsere Kafka-Implementierung auf .9 und verwenden neue Consumer-Java-API, um Consumer zu erstellen. Ich verwende unten Code für Consumer und wir verwenden das Thema zum Verbraucher w

apache-kafka kafka-consumer-api 2016-03-09

---

5Hitze

2Antwort

java.lang.NoClassDefFoundError: kafka/common/TopicAndPartition

Während der Ausführung des Befehls folgende in meinem Code: kafka_streams = [KafkaUtils.createStream(ssc, zk_settings['QUORUM'], zk_settings['CONSUMERS'][k], {zk_settings['TOPICS'][0]:

java apache-spark apache-kafka 2016-03-10

---

9Hitze

2Antwort

Hinzufügen von benutzerdefinierten Gläsern in jupyter Notebook pyspark

Ich bin mit dem Jupyter Notebook mit Pyspark mit folgendem Docker Bild: Jupyter all-spark-notebook Nun würde Ich mag eine pyspark-Streaming-Anwendung schreiben, die Nachrichten von Kafka verbraucht. I

python-3.x apache-kafka pyspark spark-streaming jupyter-notebook 2016-03-11

---

1Hitze

2Antwort

ansible Textbuch - Aufgabe nie fertig gestellt wurde, keine Ergebnisse und läuft immer noch auf meiner Konsole

Hallo hier ist mein Textbuch --- - hosts: pupservers sudo: yes tasks: - name: start kafka command: /home/ec2-user/kafka_2.11-0.9.0.0/bin/kafka-server-start.sh /home/ec2-user/kaf

linux shell unix ansible apache-kafka 2016-03-19

---

0Hitze

1Antwort

Es konnten keine Appender für den Logger gefunden werden (org.apache.kafka.clients.consumer.ConsumerConfig)

Ich versuche Apache Kafka mit Apache Flink zu verbinden, indem ich einen Kafka Consumer in Scala erstelle. Das ist mein Consumer-Code: val properties = new Properties() properties.setProperty("bootst

scala log4j apache-kafka apache-flink 2016-03-21

---

1Hitze

1Antwort

Nachricht wird zweimal verbraucht

Es gibt ein Thema mit 8 Partitionen in einem Kafka-Cluster. Ich implementiert Anwendung, um das Thema mit KafkaMessageDrivenChannelAdapter, die gleichzeitig 8 ist und OffsetManager ist KafkaTopicOffse

spring-integration apache-kafka 2016-03-21

---