load("@io_bazel_rules_go//go:def.bzl", "go_library")

go_library(
    name = "kafkaclient",
    srcs = [
        "admin.go",
        "config.go",
        "consumer.go",
        "interface.go",
        "producer.go",
    ],
    importpath = "edge-infra.dev/pkg/edge/datasync/kafkaclient",
    visibility = ["//visibility:public"],
    deps = [
        "@com_github_twmb_franz_go//pkg/kgo",
        "@com_github_twmb_franz_go//pkg/kversion",
        "@com_github_twmb_franz_go_pkg_kadm//:kadm",
    ],
)