Documentation
¶
Index ¶
- type KafkaManager
- func (k *KafkaManager) Close() error
- func (k *KafkaManager) CreateTopic(topic string)
- func (k *KafkaManager) CreateTopicFull(topic string, partitions int, rf int)
- func (k *KafkaManager) Initialize(configFile string)
- func (k *KafkaManager) InitializeSchemaRegistry(configFile string)
- func (k *KafkaManager) Produce(key []byte, data []byte, o any)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaManager ¶
type KafkaManager struct {
Topic string
Serializer string
TemplateType string
// contains filtered or unexported fields
}
func (*KafkaManager) Close ¶
func (k *KafkaManager) Close() error
func (*KafkaManager) CreateTopic ¶
func (k *KafkaManager) CreateTopic(topic string)
func (*KafkaManager) CreateTopicFull ¶
func (k *KafkaManager) CreateTopicFull(topic string, partitions int, rf int)
func (*KafkaManager) Initialize ¶
func (k *KafkaManager) Initialize(configFile string)
func (*KafkaManager) InitializeSchemaRegistry ¶
func (k *KafkaManager) InitializeSchemaRegistry(configFile string)
Source Files
Click to show internal directories.
Click to hide internal directories.