Kündigen Kafka Konsole Verbraucher wenn alle Nachrichten gelesen wurden

Weiß ich, es gibt einen Weg, um dies zu tun, aber ich bin nicht in der Lage, um dies herauszufinden. Muss ich halt die kafka-Verbraucher, wenn ich Lesen Sie alle Nachrichten aus der Warteschlange.

Kann jemand irgendwelche Infos dazu?

InformationsquelleAutor divinedragon | 2014-12-18
  1. 6

    Können Sie pass-parameter: -als Verbraucher-timeout-ms mit einem Wert, der beim starten die Verbraucher und es wird eine exception werfen wenn keine Nachrichten, die gelesen wurden, während dieser Zeit. Zum Beispiel, zu stoppen, die der Verbraucher, wenn keine neuen Nachrichten angekommen sind, in den letzten 2 Sekunden:
    kafka.Verbraucher.ConsoleConsumer -Verbraucher-timeout-ms 2000

    Können Sie sehen, dieses und alle anderen Eingabemöglichkeiten hier

    • Kannst du die komplette Befehl ? ./kafka-Konsole-Verbraucher.bat nimmt -Eigenschaft option. Das eine scheint nicht zu funktionieren.
    • Vielen Dank @Lundahl
    • Der vollständige Befehl würde dann wie folgt Aussehen: ./kafka-console-consumer.sh --bootstrap-server my-host:9092 --new-consumer --topic test-topic --from-beginning --timeout-ms 2000 ich versuchte es und es funktioniert gut, obwohl es nicht drucken eine Fehlermeldung und stack-trace, wenn er sich beendet.
    InformationsquelleAutor Lundahl
  2. 3

    Können Sie SimpleConsumerShell mit nicht-warten-auf-logend option. Sehen SystemTools-SimpleConsumerShell

    Beispiel: 

    ./kafka-run-class.bat kafka.tools.SimpleConsumerShell --broker-list localhost:9092 --topic kafkademo --partition 0 --no-wait-at-logend
    InformationsquelleAutor Ujjwal Wadhawan
  3. 2

    Derzeit, Kafka, version 2.11-2.1.1 hat ein Skript namens kafka-console-consumer.sh.

    Er hat eine neue Flagge: --timeout-ms.

    Grundsätzlich, diese Flagge ist die maximale Zeit zu warten, bevor Sie verlassen, wenn es keine neuen log zu warten. Es ist in Millisekunden Begriff.

    Können Sie diese Eigenschaft verwenden, um end-Konsole der Verbraucher nach der Lektüre all die Nachrichten.

    InformationsquelleAutor Planck35
  4. 0

    Wenn Sie nicht tot sind, legen über die Verwendung der Scala-client, die versuchen kafkacat mit der -e option, sagen Sie zu verlassen, wenn Ende der partition wurde erreicht.

    E. g. verbrauchen Sie alle Nachrichten aus mytopic partition 2 und dann Ausfahrt:

    $ kafkacat -b mybroker -t mytopic -p 2 -o beginning -e

    Konsumieren oder die letzten 3000 Meldungen und dann exit:

    $ kafkacat -b mybroker -t mytopic -p 2 -o -3000 -e
    InformationsquelleAutor Edenhill
Schreibe einen Kommentar