Categorygithub.com/DIMO-Network/devices-apiinternalkafka
package
1.31.2
Repository: https://github.com/dimo-network/devices-api.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
9
Dependents
1
Files
124 SLOC

# Functions

NewConsumer sets up watermill subscriber and returns our consumer.
No description provided by the author

# Structs

No description provided by the author
No description provided by the author
TestConsumer represents a Sarama consumer group consumer.