Я использую многопоточных потребителей кафки для одной темы кафки на 60 разделов, причем каждый поток потребителей сопоставлен с каждым разделом. После завершения потребления каждый потребительский поток закрывается с помощью метода KafkaConsumer.close ().
Во время повторного потребления с тем же групповым потребителем (поиск в начале используется для каждого пользовательского шага), 1 или 2 пользовательских потока не могутпотреблять из назначенных им разделов. Если указан новый идентификатор группы потребителей, эта проблема не отображается.
Таким образом, если приведенный ниже скрипт используется для удаления группы потребителей.
bin / kafka-consumer-groups. sh --bootstrap-servers "3 Servers: port" --delete --group group1
Это безопасный способ удаления метаданных группы потребителей, а также отключение активных соединений TCP от всехпотребители отнесены к этой группе.
Пожалуйста, поделитесь своим мнением по этому поводу.