apache-kafka

5Hitze

1Antwort

Leistungsmesswerte für Avro vs Protobuf

Wir verwenden kafka zum Speichern von Nachrichten und zum Senden einer extrem großen Anzahl von Nachrichten (> 30k in einer Minute). Ich bin mir nicht sicher, ob es relevant ist, aber der Code, der de

performance serialization apache-kafka protocol-buffers avro 2016-07-03

---

0Hitze

2Antwort

Mocking Abhängigkeit im Konstruktor initialisiert

Ich mag die Abhängigkeit in Konstruktor initialisiert verspotten, in meinem Fall habe ich Kafka Produzenten verspotten will, so dass ich das Versenden von Nachrichten über kafka spotten kann, sieht me

java junit mocking mockito apache-kafka 2016-07-04

---

0Hitze

1Antwort

flink Lesen von Daten aus kafka

ich ein einfaches Beispiel schreiben val env = StreamExecutionEnvironment.getExecutionEnvironment val properties = new Properties() properties.setProperty("bootstrap.servers","xxxxxx") properties.s

apache-kafka apache-flink 2016-07-06

---

0Hitze

1Antwort

JAVA Version Fehler mit Konfluent Kafka Avro Deserializer

Ich habe einen Server, der Java 1.6 hat. Dort muss ich Confluents KafkaAvroDeserializer verwenden, um avro-Nachrichten zu deserialisieren. Das Problem ist: Wenn ich Confluent-1.0 (die mit Java> = 1.6

java apache-kafka avro confluent 2016-07-07

---

2Hitze

1Antwort

Kafka Broker vs Thema

A Thema befindet sich normalerweise innerhalb der Broker (Server-Prozess) und hat mehrere Partitionen, aber kann es über mehrere Broker oder Knoten (Maschinen)? d. H., Ein Thema ist in zwei Partitione

apache-kafka 2016-07-07

---

0Hitze

1Antwort

Nicht in der Lage, Nachrichten zu kafka Thema über Java-Code senden

Ich benutze Kafka. Dies ist mein Code, wo ich Nachrichten an kafka server senden möchte. Der Name des Themas ist "west" mit der Nachricht "message1". Ich erhalte keinen Fehler, obwohl ich meine gesend

apache-kafka 2016-07-08

---

5Hitze

3Antwort

Kafka 0.10 Java Client TimeoutException: Batch enthält 1 Satz (e) abgelaufen

Ich habe einen einzigen Knoten, multi (3) Broker Zookeeper/Kafka-Setup. Ich benutze den Kafka 0.10 Java Client. Ich schrieb einfache Fern folgenden (auf einem anderen Server als Kafka) Produzent (im C

java apache-kafka kafka-producer-api 2016-07-08

---

0Hitze

1Antwort

Kafka Spark-Streaming-Integration

Ich habe Kafka und Funken Streaming mit Maven in meinem System eingerichtet. Ich würde gerne irgendwelche Vorschläge kennen, die mir helfen könnten, größere Operationen durchzuführen, abgesehen davon,

apache-spark apache-kafka spark-streaming 2016-07-08

---

2Hitze

1Antwort

spring-kafka (nicht integration) verbraucher keine konsummeldung

ich integriere meine anwendung mit spring-kafka (nicht feder-integration-kafka). Hier ist Frühjahr Dokumentation für das Projekt: http://docs.spring.io/spring-kafka/docs/1.0.1.RELEASE/reference/htmlsi

spring apache-kafka spring-kafka 2016-07-08

---

1Hitze

1Antwort

kafka.cluster.BrokerEndPoint kann nicht auf kafka.cluster.Broker gegossen werden

Ich versuche, Daten von kafka zu streamen Funke Ich Funke bin mit 1.6.2 mit kafka 0.9.0.1 und scala 2.11.8 alles funktioniert gut, wenn ich den Hörer basierten Ansatz verwenden (KafkaUtils.createStrea

apache-spark apache-kafka 2016-07-09

---