Я имитирую производителя кафки для чтения из файла.Я хотел бы читать из файла каждые 15 минут, так как файл меняется каждые 15 минут.Можно ли получить пример кода Python для создания темы Кафки, прочитав CSV?
+ 1 к тому, что сказал @ cricket_007. Kafka Connect специально создан для загрузки данных из других систем в Kafka (и для потоковой передачи из Kafka в другие системы, если хотите).
Соединитель, о котором он упоминает, http://github.com/jcustenborder/kafka-connect-spooldir, будет загружать файлы CSV для вас в Kafka.