confluent-kafka

1Hitze

2Antwort

Leader Nicht verfügbar Kafka in Console Producer mit ssl + acl configurations

Ich versuche kafka 0.11.0.1 mit ssl + acls zu verwenden. Meine Konfigurationen sind hier unten. server.properties: broker.id=0 listeners=PLAINTEXT://127.0.0.1:9092,SSL://127.0.0.1:9093 advertised.li

0Hitze

1Antwort

Confluence Kafka: Consumer liest nicht von Anfang an für alle Partitionen in einem Thema

Ich habe ein Thema mit 40 Partitionen. Die Einstellungen sind so: def on_assign (c,ps): for p in ps: p.offset=0 print ps c.assign(ps) conf = {'bootstrap.servers': 'localhost:9092' 'ena

-1Hitze

1Antwort

Null in Kafka Streams müssen entfernt werden

Nur entfernen --property print.key=true dies auf meinem kafka-cosole-Consumer-Befehl funktioniert für die Anzeige von null auf der Konsole .... aber die Sache ist, es ist nicht nur für die Anzeige Zwe

3Hitze

2Antwort

Streamen von Nachrichten von einem Kafka-Cluster zu einem anderen

Ich versuche derzeit, einfach Nachrichten von einem Thema auf einem Kafka-Cluster zu einem anderen zu streamen (Remote -> Lokaler Cluster). Die Idee ist, sofort Kafka-Streams zu verwenden, damit wir n

1Hitze

1Antwort

Neuester Wert von Kafka

Ich habe ein Kafka-Thema A. Format der Daten in Thema A ist: { id : 1, name:stackoverflow, created_at:2017-09-28 22:30:00.000} { id : 2, name:confluent, created_at:2017-09-28 22:00:00.000} { id : 3,

0Hitze

1Antwort

Einstellen unterschiedlicher Threads für verschiedene Operationen innerhalb Kafka Bäche

I in kafka Strom folgende Topologie definiert habe Operation 1 : input_stream ----> filter ----> window_processing ----> write_to_topic Operation 2 : input_stream ----> write_to_topic Ich habe beob

0Hitze

1Antwort

Python kann nicht fangen KafkaException von confluent_kafka

Hier ist ein Teil meines Codes ist: class KafkaProducer: def __init__(self): pass bootstrap_server_host = system_config.get_kafka_bootstrap_server() producer = Producer({'bootstr

0Hitze

1Antwort

Kafka Streams - Unbekannt Magie Byte auf GenericAvroSerde

bei dem Versuch, Avro Daten mit Kafka Streams zu streamen, stieß ich auf diesen Fehler: Exception in thread "StreamThread-1" org.apache.kafka.common.errors.SerializationException: Error deserializing

0Hitze

2Antwort

kafka-console-consumer läuft in docker container stoppt konsum von nachrichten

Ich habe konfluent kafka (v4.0.0) makler und 3 zoo keepers läuft in docker-compose. Ein Testthema wurde mit 10 Partitionen mit dem Replikationsfaktor 3 erstellt. Wenn ein Console-Consumer erstellt wir

0Hitze

2Antwort

Von .net Kerndienst mit Confluent.Kafka in Kafka schreiben

Ich habe einen .net-Kerndienst, der Daten von einem MEMSQL-Server abruft und zum Client zurückkehrt. Die Abfragen, die am Dienst generiert werden, müssen jedoch im Kafka-Cluster protokolliert werden.