Kafka Consumer API nicht mit Java-Client abonnieren

Kafka: 0.10.1.0 (Client & Server) Java-Client. Zookeeper: 3.4.6Kafka Consumer API nicht mit Java-Client abonnieren

Setup: Produzent veröffentlicht Nachrichten. Gesendete Nachrichten zum Thema Ungefahren mit ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9093 --topic TEST.TOPIC --time -1

Ausgabe Consumer wenn abgefragt, während zeichn funktioniert nicht, aber wenn Sie manuell zuweisen() - es funktioniert. Es gab eine separate thread auf derselben Frage, aber keine Antwort. Es kann ein UUID-Problem sein, benötigt aber mehr Details, da wir uns in der Evaluierungsphase befinden und Details helfen würden.

Verbrauchereinstellungen: props.put ("bootstrap.server", Server); props.put ("enable.auto.commit", ENABLE_AUTO_COMMIT);

props.put("auto.commit.interval.ms", AUTO_COMMIT_INTERVAL_MS); 
    props.put("session.timeout.ms", SESSION_TIMEOUT_MS); 
    props.put("group.id", CONSUMER_GROUP_ID); 
    props.put("key.deserializer", STRING_DESRIALIZER); 
    props.put("value.deserializer", STRING_DESRIALIZER); 
    props.put("auto.offset.reset", "earliest");

Quelle

2017-05-11 user1791646

verwenden Sie die Befehlszeile Consumer? Können Sie die Verbraucherkonfigurationen teilen? – daniel

aktualisiert. Ich benutze einen Java-Client (KafkaConsumer). Wenn ich abonniere (Themen) - funktioniert nicht. zuweisen (topicPartitions) - Works. – user1791646

Haben Sie die folgende Eigenschaft in Kafka-Eigenschaften festgelegt? 'etc/kafka/server.properties normalerweise. listeners = PLAINTEXT: // : 'Das sagt Kafka, hier im Klartext auf Konsumenten zu hören (vs ssl). – daniel

Ausgabe war mit Version von Kafka.

Switched zu 0.10.2.1 (Server und Client) und subscribe() funktionierte einwandfrei.

Quelle

2017-06-09 19:15:55 user1791646

Kafka Consumer API nicht mit Java-Client abonnieren

Antwort

Verwandte Themen