kafkaex

Imports

• github.com/IBM/sarama
• github.com/ThreeDotsLabs/watermill
• github.com/ThreeDotsLabs/watermill-kafka/v3/pkg/kafka
• github.com/ThreeDotsLabs/watermill/message
• github.com/illidaris/aphrodite/pkg/structure
• github.com/illidaris/core
• github.com/spf13/cast
• go.uber.org/zap
• go.uber.org/zap/zapcore

Standard library imports

• context
• encoding/json
• errors
• fmt
• sync
• time