connkafka

Imports

• github.com/twmb/franz-go/pkg/kadm
• github.com/twmb/franz-go/pkg/kerr
• github.com/twmb/franz-go/pkg/kgo
• github.com/twmb/franz-go/pkg/sasl/plain
• github.com/twmb/franz-go/pkg/sasl/scram
• github.com/twmb/franz-go/plugin/kslog
• github.com/yuin/gopher-lua
• go.temporal.io/sdk/log

Imports in module “github.com/PeerDB-io/peerdb/flow”

• github.com/PeerDB-io/peerdb/flow/connectors/external_metadata
• github.com/PeerDB-io/peerdb/flow/connectors/utils
• github.com/PeerDB-io/peerdb/flow/generated/protos
• github.com/PeerDB-io/peerdb/flow/model
• github.com/PeerDB-io/peerdb/flow/peerdbenv
• github.com/PeerDB-io/peerdb/flow/pua
• github.com/PeerDB-io/peerdb/flow/shared

Standard library imports

• context
• crypto/tls
• errors
• fmt
• log/slog
• sync/atomic
• time