1load("@io_bazel_rules_go//go:def.bzl", "go_library") 2 3go_library( 4 name = "kafkaclient", 5 srcs = [ 6 "admin.go", 7 "config.go", 8 "consumer.go", 9 "interface.go", 10 "producer.go", 11 ], 12 importpath = "edge-infra.dev/pkg/edge/datasync/kafkaclient", 13 visibility = ["//visibility:public"], 14 deps = [ 15 "@com_github_twmb_franz_go//pkg/kgo", 16 "@com_github_twmb_franz_go//pkg/kversion", 17 "@com_github_twmb_franz_go_pkg_kadm//:kadm", 18 ], 19)