Kafka 0,11 làm thế nào để thiết lập lại offsets

Question

Tôi đang cố gắng để đặt lại bù đắp của người tiêu dùng với các công cụ CLI mới nhất cho Kafka.

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --reset-offsets --to-earliest --all-topics 

Kết quả là tôi thấy đầu ra này:

TOPIC       PARTITION NEW-OFFSET 
FirstTopic      0   0 
SecondTopic      0   0 

Nhưng chạy lại lệnh:

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --describe 

kết quả ở đầu ra:

Consumer group 'my-group' has no active members. 

TOPIC    PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG 
FirstTopic   0   1230   1230   0 
SecondTopic  0   1022   1022   0 

Tôi đã thử khác các tùy chọn như đặt lại thành bù trừ rõ ràng hoặc sp làm chủ đề trực tiếp nhưng kết quả là giống nhau. Đầu ra cho thấy rằng hoạt động thành công trong khi kiểm tra offsets với mô tả lệnh hoặc gỡ lỗi cho thấy rằng bù đắp đã không được thay đổi.

Bất kỳ ai thành công với việc đặt lại bù trừ người tiêu dùng trong các nhà môi giới không phải sở thú.

Answer 1

Theo mặc định, --reset-offsets chỉ in kết quả của thao tác. Để thực sự thực hiện thao tác, bạn cần phải thêm --execute vào lệnh của mình:

kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group 
my-group --reset-offsets --to-earliest --all-topics --execute