Versions in this module Expand all Collapse all v1 v1.0.1 May 1, 2023 v1.0.0 Apr 30, 2023 Changes in this version + type KafkaAdapter struct + func New(w *kafka.Writer) *KafkaAdapter + func (k *KafkaAdapter) Close() error + func (k *KafkaAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, ...) error + func (k *KafkaAdapter) Publish(ctx context.Context, message discourse.Publisher) error
Go to main page