как остановить потребителя kafka python после получения записи, которую я хочу, и выполнить остальные процессы
Боюсь, нет никаких хороших независимых для платформы способов сделать это, кроме как подключиться к другому компьютеру и отправить ему ваш IP-адрес. Например: findmyipaddress . Обратите внимание, что это не сработает, если вам нужен IP-адрес за NAT, если только компьютер, к которому вы подключаетесь, находится за NAT.
Вот одно из решений, которое работает в Linux: получить IP-адрес, связанный с сетевым интерфейсом .
1 ответ
Вы можете использовать seek каждый раз, когда запускаете своего потребителя (используйте OFFSET_BEGINNING). Это установит смещение для позиции потребления для раздела. После этого продолжайте обрабатывать сообщения как обычно.
Когда вы сталкиваетесь с записью, после которой вам нужно остановить Потребителя, используйте close