Я пытаюсь проверить следующий фрагмент кода с помощью pytest: self.consumer = Consumer ({'group.id': config ['KAFKA_GROUP_ID'], 'bootstrap.servers': config ['KAFKA_BROKERS'], ...

У меня есть вопрос о том, как мы можем интегрировать производителя kafka с веб-приложением. получить данные за каждую минуту или секунду. Может ли веб-приложение каждый раз передавать объект JSON работающему производителю ...

Я реализовал потребитель Kafka, используя .net core 2.1 с Confluent.Kafka SDK (C #). Функция опроса настроена на запуск в течение 10 минут, а код развернут как лямбда-функция AWS, которая ...