Imports github.com/ThreeDotsLabs/watermill github.com/ThreeDotsLabs/watermill/message github.com/IBM/sarama github.com/ThreeDotsLabs/watermill-kafka/v3/pkg/kafka github.com/go-viper/mapstructure/v2 github.com/cyg-pd/go-watermillx/driver Standard library imports encoding/json fmt os
Go to main page