Kafka：消費者無法讀取主題中的記錄

Question

我們使用Kafka流將數據寫入接收器主題。我正在運行一個avro-consumer命令行來檢查sink主題中是否有數據：

bin/kafka-avro-console-consumer --topic sink.output.topic --from-beginning - 新的消費者--bootstrap服務器

我看到數據時，我同時運行了消費者，而卡夫卡流應用程序正在運行，但如果我停止消費，並在幾分鐘後再次運行，我沒有看到任何數據。很少的可能性：

1）這是因爲kafka流從輸出主題中消除記錄每次它推動記錄下沉？

2）或者這只是一個消費者相關的問題？

Answer 1

我認爲這是因爲--from-beginning僅在消費者尚未建立偏移量時才使用。您是否嘗試過使用--offset earliest？