Я хотел бы использовать все сообщения, начиная с начала, каждый раз, когда я запускаю потребителя в python и останавливаюсь, если я получаю желаемую запись и заканчиваю потребителя, а затем продолжаю остальные процессы.
Вы можете использовать seek каждый раз, когда запускаете своего потребителя (используйте OFFSET_BEGINNING).Это установит позицию потребления для смещения раздела.После этого продолжайте обрабатывать сообщения как обычно.
Когда вы сталкиваетесь с записью, после которой вам нужно остановить Потребителя, используйте close