2017-02-01 1 views

Antwort

1

Der Benutzer fragt nach allen Themenpartitionen (die nicht pausiert sind). Der Broker entscheidet, welche Daten zurückgegeben werden sollen. Sie können das Verhalten des Brokers nicht direkt beeinflussen.

Nicht sicher, ob RdKafka über eine API zum Pausieren und Fortsetzen von Partitionen verfügt. Ich habe jetzt nur Java KafkaConsumer, das bietet Methoden #pause() und #resume().

Verwandte Themen