🎯 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

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Terabox Video Player