Kann ich abhängig von bestimmten Bedingungen in Kafka konsumieren?

Ich schreibe eine Nachricht in Kafka und konsumiere es am anderen Ende. Man muss einen Prozess machen und es in ein anderes Kafka-Thema schreiben.Kann ich abhängig von bestimmten Bedingungen in Kafka konsumieren?

Ich mag wissen, welche Antwort-Nachricht für die Anfrage ist ..

zur Zeit beschlossen, die Offset-ID von Verbraucherseite zu erfassen dann in der Antwort schreiben und die Antwort Nutzlast lesen und das gleiche entscheiden.

Für diesen Ansatz müssen wir jede Nachricht lesen, gibt es eine andere Möglichkeit, die wir konsumabhängig konsumieren können?

Quelle

2016-09-22 Aru

Verbraucher können nur das ganze Thema lesen. Sie können Nachrichten nur über seek() überspringen, aber es gibt keine Bedingungen, die Sie auf dem Broker auswerten können, um Nachrichten zu filtern.

Sie müssen das gesamte Thema einen Prozess/Filter im Client konsumieren.

Quelle

2016-09-23 01:39:53

Danke Matthias, wir haben das per Partition behandelt. Wir haben drei Konsumenten, die Kafka Millionen von Reihen einstreuen. Jetzt haben wir maßgeschneiderte Praktiker in Hersteller und Verbraucher geschaffen. Dies reduziert die Gesamtlast. – Aru

Ich sehe. Aber das entspricht nicht wirklich Ihrer Frage. :) Wie auch immer, froh, dass du einen Weg gefunden hast, deine Bewerbung zu verbessern! –

Kann ich abhängig von bestimmten Bedingungen in Kafka konsumieren?

Antwort

Verwandte Themen