apache-kafka

0Hitze

1Antwort

Java API für kafka-acls.sh in kerberisierter Umgebung?

Ich benutze hdp 2.4 kerberised. Ich erstelle Thema dynamisch durch Java-API. Es wird erfolgreich erstellt, aber kann jemand helfen, den Zugriff für alle Benutzer zu ermöglichen, wie wir es mit kafka-a

security apache-kafka kerberos java-api 2016-03-31

---

3Hitze

1Antwort

Warum kann ich Themen nicht mithilfe der Kafka Administration-REST-API für den Message Hub von Bluemix hinzufügen und löschen?

Ich rufe die IBM Bluemix Administration API für Message Hub (aka Kafka), wie beschrieben here. Das Aufrufen des Endpunkts https://kafka-admin-prod02.messagehub.services.eu-gb.bluemix.net:443/topics (m

apache-kafka ibm-cloud messaging message-hub 2016-03-31

---

0Hitze

1Antwort

Wie kann ich ConcurrentModificationException Fehler in Kafka beheben? (0.9.0.1)

Mir ist Kafkas Aussage bekannt, dass KafkaConsumer nicht Thread-sicher ist. Also tat ich dies: (Scala) val m = Map(new TopicPartition(msg.topic(), msg.partition()) -> new OffsetAndMetadata(msg.offset(

multithreading scala apache-kafka 2016-03-31

---

1Hitze

1Antwort

Apache Kafka Mehrere Verbraucherinstanzen

Ich habe einen Verbraucher, der Nachrichten von einem Thema lesen soll. Dieser Konsument liest die Nachrichten tatsächlich und schreibt sie in eine Zeitreihen-Datenbank. Wir haben mehrere Instanzen de

apache-kafka 2016-04-01

---

1Hitze

1Antwort

Nur Tasten von Kafka lesen

Kann man nur die Tasten von Kafka lesen? Wir haben eine Anwendung, bei der die im Kafka-Protokoll gespeicherten Werte ziemlich groß sind. Um zu debuggen und schnell zu überprüfen, ob eine bestimmte Na

apache-kafka kafka-consumer-api 2016-04-01

---

1Hitze

2Antwort

kafka.common.FailedToSendMessageException: kafka produzieren Fehler

ich eine JSON-Datei lese und zu versuchen, es zu produzieren mit kafka .. Hier ist mein Code: public class FlatFileDataProducer { private String topic = "JsonTopic"; private Producer<String

apache-kafka kafka-producer-api 2016-04-01

---

1Hitze

1Antwort

Gerinne Veranstaltungen von Kafka Kanal in Spark Scala lesen?

Hallo, ich benutze den Cloudera-Kanal-Agent, um Tweets zu erhalten und Kafka als Kanal zu verwenden, um die Gerinne-Events zu halten. Die Struktur des im kafka Channel Event (Header Json Tweets) gesch

scala apache-kafka apache-spark-sql spark-streaming flume-ng 2016-04-01

---

0Hitze

1Antwort

Wie Verbraucherdaten mit Kafka Java api

Dies ist meine Verbraucher-Code überprüfen: public class KafkaConsumer { private ConsumerConnector consumerConnector = null; private final String topic = "JsonTopic"; public void init

apache-kafka kafka-consumer-api kafka-producer-api 2016-04-02

---

0Hitze

2Antwort

AssertionError: Nicht zugeordnete Partition

Im Versuch, Daten von einem Thema zu verbrauchen durch die Offset-Einstellung aber Assertionsfehler erhalten - from kafka import KafkaConsumer consumer = KafkaConsumer('foobar1', bootstrap

apache-kafka kafka-consumer-api kafka-python 2016-04-03

---

3Hitze

1Antwort

So aktivieren Kafka mit log4j Logging

I kafka-Kunden-0.9.0.0.jar mit Maven heruntergeladen und ich erwarte ich Kafka Logging Allerdings habe ich keine Ahnung, in dieser Verbindung, wie die Protokollierung würde, warum ich nicht immer jede

java log4j apache-kafka slf4j 2016-04-04

---