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 Verbrauchercode:
%Vor%Der Consumer in Kafka-net verfolgt die Offsets, die gerade verbraucht werden, nicht automatisch. Sie müssen die Offset-Verfolgung manuell implementieren.
Um den Offset in Kafka-Version 0.8.1 zu speichern:
%Vor%So legen Sie fest, dass der Verbraucher den Import an einem bestimmten Offset-Punkt beginnt:
%Vor%Beachten Sie, dass der obige Code den Verbraucher dazu bringt, am Ende des Protokolls mit dem Konsum zu beginnen, wobei er effektiv nur neue Nachrichten erhält.
Tags und Links c# apache-kafka kafka-consumer-api