A Golang project archetype for a Kafka processor application
-
Updated
Jul 20, 2017 - Go
A Golang project archetype for a Kafka processor application
The Processor API allows developers to define and connect custom processors and to interact with state stores. With the Processor API, you can define arbitrary stream processors that process one received record at a time, and connect these processors with their associated state stores to compose the processor topology that represents a customize…
Implementing the architecture of a weather monitoring system
To create Kafka producer consumer with java
Add a description, image, and links to the kafka-processor topic page so that developers can more easily learn about it.
To associate your repository with the kafka-processor topic, visit your repo's landing page and select "manage topics."