README
¶
company-search-consumer
A service that consumes messages from the stream-company-profile topic. The messages are then unmarhsalled and a RESTful request is sent to an external API with the intention of adding or updating documents present in an elastic search index.
Requirements
- Go
- Git
- Kafka - this is installed as part of the chs local build (within the chs-kafka VM)
- Kafka 2 - use this within Docker
Getting started
To build the service:
- Clone the repository
- Build the executable using:
make build
- Run the service in foreground with the start script:
./start.sh
Documentation
¶
There is no documentation for this package.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package config defines the environment variable and command-line flags
|
Package config defines the environment variable and command-line flags |
|
Package service contains the creation and start of the listener for the Kafka topic
|
Package service contains the creation and start of the listener for the Kafka topic |
|
Package upsert contains the logic to send the upsert request to the API
|
Package upsert contains the logic to send the upsert request to the API |
Click to show internal directories.
Click to hide internal directories.