๐ŸŽฏ Sending flat files to Kafka

Daniel Santos - May 3 '23 - - Dev Community

Hello ๐Ÿ–๏ธ !

Following the mechanisms described here to send CSV files into Kafka in JSON using kcat through shell pipelines, we packed ๐Ÿ“ฆ all of that in a new home-made tool named producer-file. Here are the features :

  • ๐Ÿ’จ Sending line by line
  • ๐Ÿ’ช CSV to JSON conversion
  • ๐Ÿ”ฆ Support message headers by file and/or by line
  • โšก๏ธ Delta-changes mode (only send changes occurred after last send)

โ˜๏ธ More about the shell way :

Motivations

Using jq + kcat with shell pipelines do the job well, but this doesn't fit the company's requirements today about software packaging and logging capabilities ๐Ÿคท๐Ÿปโ€โ™‚๏ธ.

๐Ÿ“ฝ๏ธ Demo

Short video demonstrating how to use this tool to send a CSV file in JSON into Kafka within a Docker environnement :

๐Ÿ“– Ressources

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .