As in topic, it is a sample of how to use GRPC server and client with Apache Kafka and its Avro package.
In this tutorial I generate random "Langitude" and "Latitude" variables and send it to Server in view of GRPC(uses protos, req/resp pipeline etc).
Kafka Consumer dispatchs all flowed data, which is wrapped with Apache Avro, to console.
- Run Zookeeper
zkserver start
- for Kafka, be carefull given path is suitable for you or not !
kafka-server-start /usr/local/etc/kafka/server.properties
- for Server
node server.js
- for Client
node client.js
- for Kafka Consumer
node kafka_consumer.js