Categorygithub.com/KyKyPy3/cleanpkgkafka
package
0.0.0-20241124113528-0de0edb5b16b
Repository: https://github.com/kykypy3/clean.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
7
Dependents
3
Files
170 SLOC

# Functions

No description provided by the author
NewConsumer kafka consumer constructor.
NewKafkaReader create new configured kafka reader.
NewProducer create new queue producer.
NewWriter create new configured kafka writer.

# Structs

No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author

# Type aliases

Worker kafka consumer worker fetch and process messages from reader.