Versions in this module Expand all Collapse all v1 v1.0.0 Jun 8, 2024 Changes in this version + const KafkaConsumerGroupKey + const KafkaPartitionKey + func NewKafkaListener(_ context.Context, config interface{}) (event.Listener, error) + func NewKafkaSender(_ context.Context, config interface{}) (event.Sender, error) + type KafkaConsumeMessage struct + func (k *KafkaConsumeMessage) Commit(ctx context.Context) error + func (k *KafkaConsumeMessage) GetEventConsumeMessage(ctx context.Context) (*event.EventConsumeMessage, error) + type KafkaIterator struct + func (k *KafkaIterator) Close() error + func (k *KafkaIterator) Next(ctx context.Context) (event.ConsumeMessage, error) + type KafkaListener struct + AuthType string + Brokers []string + CACertificate string + CertFile string + CommitInterval string + ErrorLogLevel string + HeartbeatInterval string + JoinGroupBackoff string + KeyFile string + MaxAttempts int + MaxBytes int + MaxWait string + MinBytes int + PartitionWatchInterval string + Password string + PrintLogLevel string + QueueCapacity int + ReadBackoffMax string + ReadBackoffMin string + ReadlagInterval string + RebalanceTimeout string + RetentionTime string + SessionTimeout string + StartOffset int64 + Username string + WatchPartitionChanges bool + func (k *KafkaListener) Listen(ctx context.Context, topic, group string) (event.Iterator, error) + type KafkaMessageCarrier struct + func (k KafkaMessageCarrier) Get(key string) string + func (k KafkaMessageCarrier) Keys() []string + func (k KafkaMessageCarrier) Set(key, val string) + type KafkaSender struct + AuthType string + Balancer string + BalancerConfig map[string]interface{} + BatchSize int + BatchTimeout string + Brokers []string + CACertificate string + CertFile string + ErrorLogLevel string + KeyFile string + MaxAttempts int + Password string + PrintLogLevel string + Username string + func (k *KafkaSender) Send(ctx context.Context, message *event.EventMessage) error
Go to main page