This is a simple implementation in node that subscribes to a given kafka topic then creates a Platform Event in Salesforce. It demonstrates the ability to create microservices to filter, maintain replayid's that scale independently of the Salesforce core services. The service requires a managed kafka instance to be attached.
More info about Platform Events be found here: Platform Events Developer Guide
More info about Heroku Kafka be found here: Apache Kafka on Heroku
It uses a nodejs implementation to implement a worker dyno that subscribes to a Kafka Topic. When a message is pushed into the topic an associated Salesforce Platform Event is created.
See LICENSE.
This is not an official Salesforce product.