Как разрешить пользователю AIOKafkaConsumer использовать тему Кафки, начиная с самого последнего сообщения с определенным значением

#python #apache-kafka #python-asyncio #kafka-consumer-api Вопрос: Если приложение публикует объект/словарь JSON payload в теме Кафки test с данными , которые либо содержат "type": "snapshot" , либо "type": "changes" , как мы…

Продолжить чтениеКак разрешить пользователю AIOKafkaConsumer использовать тему Кафки, начиная с самого последнего сообщения с определенным значением