Transfer data from Kafka Topic to a UDP and TCP Port-CodePudding

I try to transfer data from [tag:Kafka to udp or tcp port. I tried to find a apache-kafka-connect to achieve this goal, but I couldn't find anything related. Do you have any suggestion to find the best way to create such a pipeline?

CodePudding user response：

You can use Benthos for this. E.g.

input:
  label: "Kafka Data"
  kafka:
    addresses: ["localhost:9092"]
    topics: ["input"]
    target_version: 2.0.0
    consumer_group: "example"
output:
  label: "Socket Out"
  socket:
    network: "tcp" # or udp
    address: "host:1234"
    codec: lines