kafka_file_from_beginning.sh

#!/usr/bin/env bash
###########################################################################
#####  $Author Mike Houngbadji (mike.kenneth47@gmail.com)
#  $Description: data Real time Pipeline in kafka 
#  $History
#     20161009 @MIKE
###########################################################################

kafka_producer='$KAFKA_HOME/bin/kafka-console-producer.sh  --broker-list localhost:9092 --topic test';

file="$1";
num_line=$(wc -l "$file" | awk '{print $1}');

### Open the file content but keep it open for new incomming messages.###
### Just need to pipe the command that want to read the content of the file##

tail -n $num_line -f "$file" | $kafka_producer &