kafka-consumer-api

10Hitze

1Antwort

Benötigen Sie nähere Informationen zu Kafka auto commit und auto.commit.interval.ms

Das Dokument https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html sagt, dass "Beachten Sie, dass bei aktiviertem Auto-Commit ein Call-to-Poll immer den letzten O

kafka-consumer-api 2016-07-06

---

1Hitze

2Antwort

Kafka: kopiere Themen zwischen verschiedenen Versionen?

Ich habe zwei Makler. die erste Läufe 0.9 und die zweite Läufe 0.10 Verschiedene Arbeiter und Dämonen konsumieren und produzieren Nachrichten auf beiden Brokern. Für eine Anwendung brauche ich Nachric

apache-kafka kafka-consumer-api apache-kafka-streams 2016-07-13

---

0Hitze

1Antwort

Avro an Spark-Streaming über Kafka senden

Ich bekomme Ausgabe in Form von Byte-Array, gibt es irgendeine Funktion, um es in String zu konvertieren? stream.foreachRDD(rdd => { rdd.foreach(record => parseAVROToString(record)) }) stream.p

scala apache-spark spark-streaming kafka-consumer-api 2016-07-14

---

1Hitze

1Antwort

In Camel-Route, Code-Steuerelement nicht in der Lage, Prozess() Methode gehen

Ich versuche, Kafka-Nachrichten mit Kamel konsumieren. Der Code unten: public class Main { private static CamelContext context = new DefaultCamelContext(); public static void main(String[] args) {

apache-camel apache-kafka kafka-consumer-api 2016-07-14

---

8Hitze

1Antwort

Fehler UNKNOWN_MEMBER_ID aufgetreten, während Offsets für Gruppe xxx

Mit Kafka Client-Java-Bibliothek zu begehen, Protokolle raubend ist seit einiger Zeit gearbeitet, aber mit den folgenden Fehlern es funktioniert nicht mehr: 2016-07-15 19:37:54.609 INFO 4342 --- [main

java apache-kafka kafka-consumer-api 2016-07-15

---

0Hitze

1Antwort

Löschen unbenutzte Kafka Verbrauchergruppe

Ich verwende Confluent/Apache Kafka 0.10 mit einem kompaktierten Thema als verteilter Cache-Synchronisationsmechanismus. Wenn die Anwendung gestartet wird, wird eine instanzspezifische Benutzergruppen

apache-kafka kafka-consumer-api apache-kafka-streams confluent 2016-07-15

---

0Hitze

1Antwort

kafka Nachricht zurück in die Warteschlange stellen, ist es in Ordnung?

Ich möchte wissen, ob es möglich ist, Nachricht zurück in die Warteschlange von Kafka Verbraucher zu stellen? Was sind die besten Praktiken? Mein Fall ist: I kafka Warteschlange Nachricht A B C haben,

apache-kafka kafka-consumer-api 2016-07-20

---

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

php apache-kafka kafka-consumer-api 2016-07-21

---

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

apache-kafka kafka-consumer-api 2016-07-22

---

0Hitze

1Antwort

erklären ist/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost: 2181 --group gruppe1

Kann jemand die Ausgabe des folgenden Befehls erklären: bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group group1 Ausgang: Group Topic Pid Offset l

apache-kafka kafka-consumer-api 2016-07-25

---