Categorygithub.com/opensourceways/message-transfercommonkafka
package
0.0.0-20250115020719-a19779a20609
Repository: https://github.com/opensourceways/message-transfer.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
3
Files
51 SLOC

# Functions

Init initializes the Issue agent with the specified configuration, logger, and removeCfg flag.
SendMsg is a method on the messageAdapter struct that takes an EventMessage and sends it to the ModelCreate topic.

# Structs

Config represents the configuration for Issue.
ConsumeConfig kafka consume config.