Loading CSV data into Kafka

Question

I was working on event monitoring / microservice monitoring with kafka.

Following a guide from https://rmoff.net/2020/06/17/loading-csv-data-into-kafka/

When i was at the area

    kafkacat -b kafka:29092 -t orders_spooldir_00 \
             -C -o-1 -J \
             -s key=s -s value=avro -r http://schema-registry:8081 | \
             jq '.payload'

I got an error, not sure what went wrong, docker end or the server end? Would appreciate any helps on how I can proceed! thanks

% ERROR: Failed to query metadata for topic orders_spooldir_00: Local: Broker transport failure

kafka-connect      | [2021-11-09 16:02:35,778] ERROR [source-csv-spooldir-00|worker] WorkerConnector{id=source-csv-spooldir-00} Error while starting connector (org.apache.kafka.connect.runtime.WorkerConnector:193)

Loading CSV data into Kafka

0 Answers