kafka

Imports

• github.com/confluentinc/confluent-kafka-go/kafka
• github.com/go-logr/logr
• github.com/stolostron/hub-of-hubs-kafka-transport/headers
• github.com/stolostron/hub-of-hubs-kafka-transport/kafka-client/kafka-consumer

Imports in module “github.com/stolostron/hub-of-hubs-manager”

• github.com/stolostron/hub-of-hubs-manager/pkg/compressor
• github.com/stolostron/hub-of-hubs-manager/pkg/statistics
• github.com/stolostron/hub-of-hubs-manager/pkg/statussyncer/transport2db/conflator
• github.com/stolostron/hub-of-hubs-manager/pkg/statussyncer/transport2db/transport

Standard library imports

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