Imports github.com/lib/pq go.uber.org/zap github.com/blendle/go-logger github.com/pkg/errors github.com/blendle/pg2kafka/eventqueue github.com/confluentinc/confluent-kafka-go/kafka Standard library imports encoding/json fmt net/url os os/signal strings time