apache-kafka

8Hitze

1Antwort

Konfiguriere kafka-net um das Senden der letzten Nachrichten zu beenden

Ich benutze kafka 0.8.1.1 auf einer Red Hat VM mit kafka-net plugin. Wie kann ich meinen Kunden so konfigurieren, dass er keine früheren Nachrichten von kafka mehr empfängt? Mein Verbraucher Code: var

10Hitze

1Antwort

Verpflichtet commitOffsets auf High-Level-Consumer-Block?

Im Java-Client (http://kafka.apache.org/documentation.html#highlevelconsumerapi), setzt commitOffsets auf dem High-Level-Consumer-Block ein, bis Offsets erfolgreich ausgeführt wurden, oder ist es Fire

6Hitze

1Antwort

Kann nicht kommunizieren mit Kafka-Server mit kafka Producer API

Ich habe kafka auf einem einzigen Knoten eingerichtet und zookeeper sowie Kafka-Server gestartet.Ich habe es für interne Produzent und Verbraucher auf der Konsole getestet und es funktioniert gut.Aber

28Hitze

3Antwort

Ändern der Kafka-Aufbewahrungsdauer während der Laufzeit

Wie ändere ich mit Kafka 0.8.1.1 die Aufbewahrungszeit des Protokolls, während es läuft? Die documentation sagt der Eigenschaft ist , aber ich versuche, es zu ändern kafka-topics.sh kehrt mit diesem F

9Hitze

1Antwort

Confluent Plattform: Schema Registry Themen

Arbeiten mit Confluent Plattform, die Plattform von den Machern von Apache Kafka angeboten, und ich habe eine Frage: In der Dokumentation der Schema Registry API Reference, erwähnen sie die Abstraktio

5Hitze

1Antwort

Oracle Change-Datenerfassung mit Kafka Best Practices

Ich arbeite an einem Projekt, wo wir Echtzeit-Updates von Oracle auf eine Reihe von Systemen (Cassandra, Hadoop, Echtzeitverarbeitung, etc.) streamen müssen. Wir planen, Golden Gate zu verwenden, um d

16Hitze

1Antwort

Können wir eine starke Routing-Fähigkeit mit Apache Kafka ähnlich wie RabbitMq haben?

Wir versuchen, Kafka zu bewerten und Rabbit Mq in unserer Software zu ersetzen. Wir kennen die Vorteile von Kafka in Bezug auf RabbitMq gegenüber Offline-Verbrauch, enorme Persistenz, hervorragende Le

6Hitze

2Antwort

org.apache.spark.SparkException: Aufgabe nicht serializable

Dies ist ein Arbeitscodebeispiel: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> lines = m

14Hitze

2Antwort

Wie kann ich einen Kafka-Ausfall elegant bewältigen?

Ich verbinde mich mit Kafka über die 0.8.2.1 kafka-clients-Bibliothek. Ich bin in der Lage, erfolgreich eine Verbindung herzustellen, wenn Kafka aktiv ist, aber ich möchte einen Fehler beheben, wenn K

21Hitze

1Antwort

Ob Schlüssel als Teil des Senden Nachricht in kafka

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(),SerializationUtils.serialize(message)); producer.send(keyedMessage); Zur Zeit erforderlich si