From 1efc6b5a6944245eeb3c87ff4fbf38576fa743da Mon Sep 17 00:00:00 2001 From: Dirk Wilden Date: Fri, 8 Mar 2024 11:39:55 +0100 Subject: [PATCH] update go module to /v5 --- cmd/alter/alter-partition.go | 10 ++--- cmd/alter/alter-partition_test.go | 4 +- cmd/alter/alter-topic.go | 8 ++-- cmd/alter/alter-topic_test.go | 4 +- cmd/attach/attach.go | 4 +- cmd/clone/clone-consumergroup.go | 8 ++-- cmd/clone/clone-consumergroup_test.go | 2 +- cmd/clone/clone-topic.go | 6 +-- cmd/clone/clone-topic_test.go | 4 +- cmd/completion.go | 2 +- cmd/config/currentContext.go | 4 +- cmd/config/getContexts.go | 4 +- cmd/config/useContext.go | 4 +- cmd/config/useContext_test.go | 2 +- cmd/config/view.go | 2 +- cmd/config/view_test.go | 4 +- cmd/consume/consume.go | 10 ++--- cmd/consume/consume_test.go | 4 +- cmd/create/create-acl.go | 10 ++--- cmd/create/create-acl_test.go | 2 +- cmd/create/create-consumergroup.go | 6 +-- cmd/create/create-topic.go | 6 +-- cmd/create/create-topic_test.go | 2 +- cmd/deletion/delete-acl.go | 6 +-- cmd/deletion/delete-acl_test.go | 2 +- cmd/deletion/delete-consumer-group-offset.go | 8 ++-- .../delete-consumer-group-offset_test.go | 4 +- cmd/deletion/delete-consumer-group.go | 6 +-- cmd/deletion/delete-consumer-group_test.go | 4 +- cmd/deletion/delete-records.go | 8 ++-- cmd/deletion/delete-records_test.go | 2 +- cmd/deletion/delete-topic.go | 6 +-- cmd/deletion/delete-topic_test.go | 4 +- cmd/describe/describe-broker.go | 6 +-- cmd/describe/describe-broker_test.go | 4 +- cmd/describe/describe-consumer-group.go | 8 ++-- cmd/describe/describe-consumer-group_test.go | 2 +- cmd/describe/describe-topic.go | 6 +-- cmd/describe/describe-topic_test.go | 6 +-- cmd/docs.go | 4 +- cmd/get/get-acl.go | 6 +-- cmd/get/get-acl_test.go | 2 +- cmd/get/get-brokers.go | 6 +-- cmd/get/get-brokers_test.go | 2 +- cmd/get/get-consumer-groups.go | 8 ++-- cmd/get/get-consumer-groups_test.go | 2 +- cmd/get/get-topics.go | 6 +-- cmd/get/get-topics_test.go | 2 +- cmd/produce/produce.go | 8 ++-- cmd/produce/produce_test.go | 4 +- cmd/reset/reset-consumer-group-offset.go | 8 ++-- cmd/reset/reset-consumer-group-offset_test.go | 2 +- cmd/root.go | 28 ++++++------- cmd/root_test.go | 4 +- cmd/version.go | 2 +- cmd/version_test.go | 4 +- go.mod | 40 +++++++++---------- go.sum | 39 ++++++++++++++++++ internal/acl/acl-operation.go | 4 +- internal/acl/type-formatter.go | 2 +- internal/auth/token-provider.go | 4 +- internal/broker/broker-operation.go | 4 +- internal/common-operation.go | 12 +++--- internal/consume/AvroMessageDeserializer.go | 6 +-- .../consume/DefaultMessageDeserializer.go | 2 +- internal/consume/GroupConsumer.go | 2 +- internal/consume/PartitionConsumer.go | 4 +- .../consume/ProtobufMessageDeserializer.go | 4 +- internal/consume/consume-operation.go | 6 +-- .../OffsetResettingConsumer.go | 4 +- .../consumer-group-offset-operation.go | 8 ++-- .../consumer-group-operation.go | 6 +-- internal/docs-operation.go | 2 +- internal/global/config.go | 2 +- internal/helpers/TerminalContext.go | 2 +- internal/helpers/avro/JsonCodec.go | 2 +- internal/helpers/protobuf/protobuf.go | 2 +- internal/k8s/executer_test.go | 6 +-- internal/k8s/executor.go | 4 +- internal/k8s/k8s-operation.go | 6 +-- internal/k8s/k8s-operation_test.go | 10 ++--- internal/k8s/runner.go | 2 +- internal/partition/partition-operation.go | 4 +- internal/producer/AvroMessageSerializer.go | 4 +- .../producer/ProtobufMessageSerializer.go | 2 +- internal/producer/input/csv_parser.go | 4 +- internal/producer/producer-operation.go | 8 ++-- internal/testutil/helpers.go | 2 +- internal/testutil/test_util.go | 10 ++--- internal/topic/topic-operation.go | 6 +-- internal/util/parse_offsets_test.go | 2 +- main.go | 4 +- pkg/plugins/auth/interface.go | 2 +- pkg/plugins/plugin.go | 4 +- 94 files changed, 284 insertions(+), 245 deletions(-) diff --git a/cmd/alter/alter-partition.go b/cmd/alter/alter-partition.go index 3b6af7c1..fb21ae11 100644 --- a/cmd/alter/alter-partition.go +++ b/cmd/alter/alter-partition.go @@ -3,11 +3,11 @@ package alter import ( "strconv" - "github.com/deviceinsight/kafkactl/cmd/validation" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/partition" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/cmd/validation" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/partition" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/cmd/alter/alter-partition_test.go b/cmd/alter/alter-partition_test.go index c783f080..8a5ffa87 100644 --- a/cmd/alter/alter-partition_test.go +++ b/cmd/alter/alter-partition_test.go @@ -8,8 +8,8 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "gopkg.in/errgo.v2/fmt/errors" ) diff --git a/cmd/alter/alter-topic.go b/cmd/alter/alter-topic.go index f83e9355..f507cd92 100644 --- a/cmd/alter/alter-topic.go +++ b/cmd/alter/alter-topic.go @@ -1,10 +1,10 @@ package alter import ( - "github.com/deviceinsight/kafkactl/cmd/validation" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/cmd/validation" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/alter/alter-topic_test.go b/cmd/alter/alter-topic_test.go index af8fc56d..52cd5677 100644 --- a/cmd/alter/alter-topic_test.go +++ b/cmd/alter/alter-topic_test.go @@ -8,8 +8,8 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "gopkg.in/errgo.v2/fmt/errors" ) diff --git a/cmd/attach/attach.go b/cmd/attach/attach.go index a6dde9fa..b5fc55ca 100644 --- a/cmd/attach/attach.go +++ b/cmd/attach/attach.go @@ -1,8 +1,8 @@ package attach import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/clone/clone-consumergroup.go b/cmd/clone/clone-consumergroup.go index 59f312d8..8248cea5 100644 --- a/cmd/clone/clone-consumergroup.go +++ b/cmd/clone/clone-consumergroup.go @@ -1,10 +1,10 @@ package clone import ( - "github.com/deviceinsight/kafkactl/internal/consumergroupoffsets" - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroupoffsets" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/clone/clone-consumergroup_test.go b/cmd/clone/clone-consumergroup_test.go index 8801575d..a93e82df 100644 --- a/cmd/clone/clone-consumergroup_test.go +++ b/cmd/clone/clone-consumergroup_test.go @@ -4,7 +4,7 @@ import ( "fmt" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestCloneConsumerGroupIntegration(t *testing.T) { diff --git a/cmd/clone/clone-topic.go b/cmd/clone/clone-topic.go index 3564f04a..e7532634 100644 --- a/cmd/clone/clone-topic.go +++ b/cmd/clone/clone-topic.go @@ -1,9 +1,9 @@ package clone import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/clone/clone-topic_test.go b/cmd/clone/clone-topic_test.go index c50345aa..75f7d123 100644 --- a/cmd/clone/clone-topic_test.go +++ b/cmd/clone/clone-topic_test.go @@ -10,8 +10,8 @@ import ( "github.com/Rican7/retry/strategy" "gopkg.in/errgo.v2/fmt/errors" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/topic" ) func TestCloneTopicIntegration(t *testing.T) { diff --git a/cmd/completion.go b/cmd/completion.go index c1cbb9e5..939f0174 100644 --- a/cmd/completion.go +++ b/cmd/completion.go @@ -3,7 +3,7 @@ package cmd import ( "os" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/cmd/config/currentContext.go b/cmd/config/currentContext.go index fd925000..d2d2902a 100644 --- a/cmd/config/currentContext.go +++ b/cmd/config/currentContext.go @@ -1,8 +1,8 @@ package config import ( - "github.com/deviceinsight/kafkactl/internal/global" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/config/getContexts.go b/cmd/config/getContexts.go index 7ab998db..c9eb9ee4 100644 --- a/cmd/config/getContexts.go +++ b/cmd/config/getContexts.go @@ -1,8 +1,8 @@ package config import ( - "github.com/deviceinsight/kafkactl/internal/global" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" "github.com/spf13/viper" diff --git a/cmd/config/useContext.go b/cmd/config/useContext.go index d3f19b50..887bbafa 100644 --- a/cmd/config/useContext.go +++ b/cmd/config/useContext.go @@ -3,9 +3,9 @@ package config import ( "sort" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "strings" diff --git a/cmd/config/useContext_test.go b/cmd/config/useContext_test.go index 6c902af3..44d7dce5 100644 --- a/cmd/config/useContext_test.go +++ b/cmd/config/useContext_test.go @@ -4,7 +4,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestUseContextAutoCompletionIntegration(t *testing.T) { diff --git a/cmd/config/view.go b/cmd/config/view.go index 5eb92f30..373afe2b 100644 --- a/cmd/config/view.go +++ b/cmd/config/view.go @@ -3,7 +3,7 @@ package config import ( "os" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" "github.com/spf13/viper" diff --git a/cmd/config/view_test.go b/cmd/config/view_test.go index fb60f4ac..d7ddb89b 100644 --- a/cmd/config/view_test.go +++ b/cmd/config/view_test.go @@ -5,8 +5,8 @@ import ( "path" "testing" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestViewConfigWithEnvVariablesInGeneratedConfigSet(t *testing.T) { diff --git a/cmd/consume/consume.go b/cmd/consume/consume.go index b722736f..1d703e31 100644 --- a/cmd/consume/consume.go +++ b/cmd/consume/consume.go @@ -1,11 +1,11 @@ package consume import ( - "github.com/deviceinsight/kafkactl/internal/consume" - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/consume" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/consume/consume_test.go b/cmd/consume/consume_test.go index 7b50bcf5..53aaf72c 100644 --- a/cmd/consume/consume_test.go +++ b/cmd/consume/consume_test.go @@ -8,9 +8,9 @@ import ( "testing" "time" - "github.com/deviceinsight/kafkactl/internal/helpers/protobuf" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/protobuf" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" "github.com/jhump/protoreflect/dynamic" "google.golang.org/protobuf/types/known/timestamppb" ) diff --git a/cmd/create/create-acl.go b/cmd/create/create-acl.go index 935a14cf..ab780837 100644 --- a/cmd/create/create-acl.go +++ b/cmd/create/create-acl.go @@ -1,11 +1,11 @@ package create import ( - "github.com/deviceinsight/kafkactl/internal/acl" - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/acl" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/create/create-acl_test.go b/cmd/create/create-acl_test.go index 5de1836d..c9ee61da 100644 --- a/cmd/create/create-acl_test.go +++ b/cmd/create/create-acl_test.go @@ -4,7 +4,7 @@ import ( "fmt" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestCreateTopicReadAclIntegration(t *testing.T) { diff --git a/cmd/create/create-consumergroup.go b/cmd/create/create-consumergroup.go index 570c2039..d43d7516 100644 --- a/cmd/create/create-consumergroup.go +++ b/cmd/create/create-consumergroup.go @@ -1,9 +1,9 @@ package create import ( - "github.com/deviceinsight/kafkactl/internal/consumergroupoffsets" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroupoffsets" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/create/create-topic.go b/cmd/create/create-topic.go index e53ef818..0c5bfaef 100644 --- a/cmd/create/create-topic.go +++ b/cmd/create/create-topic.go @@ -1,9 +1,9 @@ package create import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/create/create-topic_test.go b/cmd/create/create-topic_test.go index f6f3206f..f2ce5529 100644 --- a/cmd/create/create-topic_test.go +++ b/cmd/create/create-topic_test.go @@ -8,7 +8,7 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestCreateTopicWithoutFlagsIntegration(t *testing.T) { diff --git a/cmd/deletion/delete-acl.go b/cmd/deletion/delete-acl.go index 932ec8b1..c9971b8d 100644 --- a/cmd/deletion/delete-acl.go +++ b/cmd/deletion/delete-acl.go @@ -1,9 +1,9 @@ package deletion import ( - "github.com/deviceinsight/kafkactl/internal/acl" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/acl" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/deletion/delete-acl_test.go b/cmd/deletion/delete-acl_test.go index 88de127c..9a686407 100644 --- a/cmd/deletion/delete-acl_test.go +++ b/cmd/deletion/delete-acl_test.go @@ -4,7 +4,7 @@ import ( "fmt" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestDeleteTopicReadAclIntegration(t *testing.T) { diff --git a/cmd/deletion/delete-consumer-group-offset.go b/cmd/deletion/delete-consumer-group-offset.go index e1bac1d5..e6ee4e4b 100644 --- a/cmd/deletion/delete-consumer-group-offset.go +++ b/cmd/deletion/delete-consumer-group-offset.go @@ -1,10 +1,10 @@ package deletion import ( - "github.com/deviceinsight/kafkactl/internal/consumergroupoffsets" - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroupoffsets" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/deletion/delete-consumer-group-offset_test.go b/cmd/deletion/delete-consumer-group-offset_test.go index 4f683f35..8183d74c 100644 --- a/cmd/deletion/delete-consumer-group-offset_test.go +++ b/cmd/deletion/delete-consumer-group-offset_test.go @@ -11,8 +11,8 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" ) diff --git a/cmd/deletion/delete-consumer-group.go b/cmd/deletion/delete-consumer-group.go index e37f829e..f8c4a7a1 100644 --- a/cmd/deletion/delete-consumer-group.go +++ b/cmd/deletion/delete-consumer-group.go @@ -1,9 +1,9 @@ package deletion import ( - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/deletion/delete-consumer-group_test.go b/cmd/deletion/delete-consumer-group_test.go index 799e1ce8..6f866ff7 100644 --- a/cmd/deletion/delete-consumer-group_test.go +++ b/cmd/deletion/delete-consumer-group_test.go @@ -10,8 +10,8 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/util" ) func TestDeleteSingleConsumerGroupIntegration(t *testing.T) { diff --git a/cmd/deletion/delete-records.go b/cmd/deletion/delete-records.go index d0cd8a68..743795bd 100644 --- a/cmd/deletion/delete-records.go +++ b/cmd/deletion/delete-records.go @@ -1,10 +1,10 @@ package deletion import ( - "github.com/deviceinsight/kafkactl/cmd/validation" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/cmd/validation" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/deletion/delete-records_test.go b/cmd/deletion/delete-records_test.go index 89ee05a1..a53de385 100644 --- a/cmd/deletion/delete-records_test.go +++ b/cmd/deletion/delete-records_test.go @@ -4,7 +4,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestDeleteRecordsIntegration(t *testing.T) { diff --git a/cmd/deletion/delete-topic.go b/cmd/deletion/delete-topic.go index b21114b2..574ab6d8 100644 --- a/cmd/deletion/delete-topic.go +++ b/cmd/deletion/delete-topic.go @@ -1,9 +1,9 @@ package deletion import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/deletion/delete-topic_test.go b/cmd/deletion/delete-topic_test.go index 69b09d12..ba7d84a2 100644 --- a/cmd/deletion/delete-topic_test.go +++ b/cmd/deletion/delete-topic_test.go @@ -10,8 +10,8 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/testutil" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/util" ) func TestDeleteSingleTopicIntegration(t *testing.T) { diff --git a/cmd/describe/describe-broker.go b/cmd/describe/describe-broker.go index ae4e27b6..9cbd9774 100644 --- a/cmd/describe/describe-broker.go +++ b/cmd/describe/describe-broker.go @@ -3,9 +3,9 @@ package describe import ( "strconv" - "github.com/deviceinsight/kafkactl/internal/broker" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/broker" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/describe/describe-broker_test.go b/cmd/describe/describe-broker_test.go index 2796c3e2..59bac5ed 100644 --- a/cmd/describe/describe-broker_test.go +++ b/cmd/describe/describe-broker_test.go @@ -5,9 +5,9 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/broker" + "github.com/deviceinsight/kafkactl/v5/internal/broker" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestDescribeBrokerIntegration(t *testing.T) { diff --git a/cmd/describe/describe-consumer-group.go b/cmd/describe/describe-consumer-group.go index 93f31e19..618618ef 100644 --- a/cmd/describe/describe-consumer-group.go +++ b/cmd/describe/describe-consumer-group.go @@ -1,10 +1,10 @@ package describe import ( - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/describe/describe-consumer-group_test.go b/cmd/describe/describe-consumer-group_test.go index 6fe364f3..fc76ebe2 100644 --- a/cmd/describe/describe-consumer-group_test.go +++ b/cmd/describe/describe-consumer-group_test.go @@ -4,7 +4,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestDescribeConsumerGroupTopicAutoCompletionIntegration(t *testing.T) { diff --git a/cmd/describe/describe-topic.go b/cmd/describe/describe-topic.go index 9321facd..90114e48 100644 --- a/cmd/describe/describe-topic.go +++ b/cmd/describe/describe-topic.go @@ -1,9 +1,9 @@ package describe import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/describe/describe-topic_test.go b/cmd/describe/describe-topic_test.go index fb114d4d..ee142d59 100644 --- a/cmd/describe/describe-topic_test.go +++ b/cmd/describe/describe-topic_test.go @@ -4,10 +4,10 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/topic" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestDescribeTopicConfigsIntegration(t *testing.T) { diff --git a/cmd/docs.go b/cmd/docs.go index 515ae9c2..041e4723 100644 --- a/cmd/docs.go +++ b/cmd/docs.go @@ -1,8 +1,8 @@ package cmd import ( - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/get/get-acl.go b/cmd/get/get-acl.go index 27bd6007..0c374dfe 100644 --- a/cmd/get/get-acl.go +++ b/cmd/get/get-acl.go @@ -1,9 +1,9 @@ package get import ( - "github.com/deviceinsight/kafkactl/internal/acl" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/acl" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/get/get-acl_test.go b/cmd/get/get-acl_test.go index 8ee11e44..458b081f 100644 --- a/cmd/get/get-acl_test.go +++ b/cmd/get/get-acl_test.go @@ -6,7 +6,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestGetTopicReadAclIntegration(t *testing.T) { diff --git a/cmd/get/get-brokers.go b/cmd/get/get-brokers.go index d2690710..9f29baa5 100644 --- a/cmd/get/get-brokers.go +++ b/cmd/get/get-brokers.go @@ -1,9 +1,9 @@ package get import ( - "github.com/deviceinsight/kafkactl/internal/broker" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/broker" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/get/get-brokers_test.go b/cmd/get/get-brokers_test.go index 064e2bdb..c79b516a 100644 --- a/cmd/get/get-brokers_test.go +++ b/cmd/get/get-brokers_test.go @@ -3,7 +3,7 @@ package get_test import ( "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestGetBrokersIntegration(t *testing.T) { diff --git a/cmd/get/get-consumer-groups.go b/cmd/get/get-consumer-groups.go index 099561ee..430b7b47 100644 --- a/cmd/get/get-consumer-groups.go +++ b/cmd/get/get-consumer-groups.go @@ -1,10 +1,10 @@ package get import ( - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/get/get-consumer-groups_test.go b/cmd/get/get-consumer-groups_test.go index cf4916af..81148a71 100644 --- a/cmd/get/get-consumer-groups_test.go +++ b/cmd/get/get-consumer-groups_test.go @@ -4,7 +4,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestGetConsumerGroupsAutoCompletionIntegration(t *testing.T) { diff --git a/cmd/get/get-topics.go b/cmd/get/get-topics.go index 6f919c65..127aad35 100644 --- a/cmd/get/get-topics.go +++ b/cmd/get/get-topics.go @@ -1,9 +1,9 @@ package get import ( - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/get/get-topics_test.go b/cmd/get/get-topics_test.go index 95815d8f..529a2901 100644 --- a/cmd/get/get-topics_test.go +++ b/cmd/get/get-topics_test.go @@ -4,7 +4,7 @@ import ( "fmt" "testing" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestGetTopicsShowsMinReplicationFactorOfPartitionsIntegration(t *testing.T) { diff --git a/cmd/produce/produce.go b/cmd/produce/produce.go index c2c28197..73e6f7f2 100644 --- a/cmd/produce/produce.go +++ b/cmd/produce/produce.go @@ -3,10 +3,10 @@ package produce import ( "fmt" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/producer" - "github.com/deviceinsight/kafkactl/internal/topic" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/producer" + "github.com/deviceinsight/kafkactl/v5/internal/topic" "github.com/spf13/cobra" ) diff --git a/cmd/produce/produce_test.go b/cmd/produce/produce_test.go index 37d15839..b19de1ab 100644 --- a/cmd/produce/produce_test.go +++ b/cmd/produce/produce_test.go @@ -10,11 +10,11 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/helpers/protobuf" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/protobuf" "github.com/jhump/protoreflect/dynamic" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestProduceWithKeyAndValueIntegration(t *testing.T) { diff --git a/cmd/reset/reset-consumer-group-offset.go b/cmd/reset/reset-consumer-group-offset.go index 064c369b..1e95738b 100644 --- a/cmd/reset/reset-consumer-group-offset.go +++ b/cmd/reset/reset-consumer-group-offset.go @@ -1,10 +1,10 @@ package reset import ( - "github.com/deviceinsight/kafkactl/internal/consumergroupoffsets" - "github.com/deviceinsight/kafkactl/internal/consumergroups" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroupoffsets" + "github.com/deviceinsight/kafkactl/v5/internal/consumergroups" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/reset/reset-consumer-group-offset_test.go b/cmd/reset/reset-consumer-group-offset_test.go index 0eaa1d7c..77c902e4 100644 --- a/cmd/reset/reset-consumer-group-offset_test.go +++ b/cmd/reset/reset-consumer-group-offset_test.go @@ -5,7 +5,7 @@ import ( "testing" "time" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestResetCGOForSingleTopicIntegration(t *testing.T) { diff --git a/cmd/root.go b/cmd/root.go index 11a88892..15c402cb 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -3,21 +3,21 @@ package cmd import ( "fmt" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/cmd/alter" - "github.com/deviceinsight/kafkactl/cmd/attach" - "github.com/deviceinsight/kafkactl/cmd/clone" - "github.com/deviceinsight/kafkactl/cmd/config" - "github.com/deviceinsight/kafkactl/cmd/consume" - "github.com/deviceinsight/kafkactl/cmd/create" - "github.com/deviceinsight/kafkactl/cmd/deletion" - "github.com/deviceinsight/kafkactl/cmd/describe" - "github.com/deviceinsight/kafkactl/cmd/get" - "github.com/deviceinsight/kafkactl/cmd/produce" - "github.com/deviceinsight/kafkactl/cmd/reset" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/cmd/alter" + "github.com/deviceinsight/kafkactl/v5/cmd/attach" + "github.com/deviceinsight/kafkactl/v5/cmd/clone" + "github.com/deviceinsight/kafkactl/v5/cmd/config" + "github.com/deviceinsight/kafkactl/v5/cmd/consume" + "github.com/deviceinsight/kafkactl/v5/cmd/create" + "github.com/deviceinsight/kafkactl/v5/cmd/deletion" + "github.com/deviceinsight/kafkactl/v5/cmd/describe" + "github.com/deviceinsight/kafkactl/v5/cmd/get" + "github.com/deviceinsight/kafkactl/v5/cmd/produce" + "github.com/deviceinsight/kafkactl/v5/cmd/reset" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/root_test.go b/cmd/root_test.go index 40931551..b3258ee5 100644 --- a/cmd/root_test.go +++ b/cmd/root_test.go @@ -5,9 +5,9 @@ import ( "os" "testing" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" "github.com/spf13/viper" ) diff --git a/cmd/version.go b/cmd/version.go index 97786366..17838b76 100644 --- a/cmd/version.go +++ b/cmd/version.go @@ -4,7 +4,7 @@ import ( "fmt" "runtime" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/cobra" ) diff --git a/cmd/version_test.go b/cmd/version_test.go index 5c7a031c..039abcfb 100644 --- a/cmd/version_test.go +++ b/cmd/version_test.go @@ -4,8 +4,8 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/cmd" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/cmd" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestVersionCommand(t *testing.T) { diff --git a/go.mod b/go.mod index ebfa0b6b..ca78f3a7 100644 --- a/go.mod +++ b/go.mod @@ -1,13 +1,14 @@ -module github.com/deviceinsight/kafkactl +module github.com/deviceinsight/kafkactl/v5 go 1.21.6 require ( - github.com/IBM/sarama v1.42.1 + github.com/IBM/sarama v1.43.0 github.com/Rican7/retry v0.3.1 - github.com/golang/protobuf v1.5.3 + github.com/golang/protobuf v1.5.4 + github.com/hashicorp/go-hclog v1.6.2 github.com/hashicorp/go-plugin v1.6.0 - github.com/jhump/protoreflect v1.15.4 + github.com/jhump/protoreflect v1.15.6 github.com/landoop/schema-registry v0.0.0-20190327143759-50a5701c1891 github.com/linkedin/goavro/v2 v2.12.0 github.com/pkg/errors v0.9.1 @@ -15,26 +16,25 @@ require ( github.com/spf13/pflag v1.0.5 github.com/spf13/viper v1.18.2 github.com/xdg-go/scram v1.1.2 - go.uber.org/ratelimit v0.3.0 + go.uber.org/ratelimit v0.3.1 golang.org/x/sync v0.6.0 - google.golang.org/protobuf v1.32.0 + google.golang.org/protobuf v1.33.0 gopkg.in/errgo.v2 v2.1.0 gopkg.in/yaml.v2 v2.4.0 ) require ( github.com/benbjohnson/clock v1.3.5 // indirect - github.com/bufbuild/protocompile v0.7.1 // indirect + github.com/bufbuild/protocompile v0.9.0 // indirect github.com/cpuguy83/go-md2man/v2 v2.0.3 // indirect github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect - github.com/eapache/go-resiliency v1.5.0 // indirect + github.com/eapache/go-resiliency v1.6.0 // indirect github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 // indirect github.com/eapache/queue v1.1.0 // indirect - github.com/fatih/color v1.14.1 // indirect + github.com/fatih/color v1.16.0 // indirect github.com/fsnotify/fsnotify v1.7.0 // indirect github.com/golang/snappy v0.0.4 // indirect github.com/hashicorp/errwrap v1.1.0 // indirect - github.com/hashicorp/go-hclog v1.5.0 // indirect github.com/hashicorp/go-multierror v1.1.1 // indirect github.com/hashicorp/go-uuid v1.0.3 // indirect github.com/hashicorp/hcl v1.0.0 // indirect @@ -45,13 +45,13 @@ require ( github.com/jcmturner/gofork v1.7.6 // indirect github.com/jcmturner/gokrb5/v8 v8.4.4 // indirect github.com/jcmturner/rpc/v2 v2.0.3 // indirect - github.com/klauspost/compress v1.17.4 // indirect + github.com/klauspost/compress v1.17.7 // indirect github.com/magiconair/properties v1.8.7 // indirect github.com/mattn/go-colorable v0.1.13 // indirect - github.com/mattn/go-isatty v0.0.17 // indirect - github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/mitchellh/go-testing-interface v1.14.1 // indirect github.com/mitchellh/mapstructure v1.5.0 // indirect - github.com/oklog/run v1.0.0 // indirect + github.com/oklog/run v1.1.0 // indirect github.com/pelletier/go-toml/v2 v2.1.1 // indirect github.com/pierrec/lz4/v4 v4.1.21 // indirect github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect @@ -67,13 +67,13 @@ require ( github.com/xdg-go/stringprep v1.0.4 // indirect go.uber.org/atomic v1.11.0 // indirect go.uber.org/multierr v1.11.0 // indirect - golang.org/x/crypto v0.18.0 // indirect - golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 // indirect - golang.org/x/net v0.20.0 // indirect - golang.org/x/sys v0.16.0 // indirect + golang.org/x/crypto v0.21.0 // indirect + golang.org/x/exp v0.0.0-20240222234643-814bf88cf225 // indirect + golang.org/x/net v0.22.0 // indirect + golang.org/x/sys v0.18.0 // indirect golang.org/x/text v0.14.0 // indirect - google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac // indirect - google.golang.org/grpc v1.60.1 // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20240304212257-790db918fca8 // indirect + google.golang.org/grpc v1.62.1 // indirect gopkg.in/ini.v1 v1.67.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index d63daec7..2839a71e 100644 --- a/go.sum +++ b/go.sum @@ -1,11 +1,15 @@ github.com/IBM/sarama v1.42.1 h1:wugyWa15TDEHh2kvq2gAy1IHLjEjuYOYgXz/ruC/OSQ= github.com/IBM/sarama v1.42.1/go.mod h1:Xxho9HkHd4K/MDUo/T/sOqwtX/17D33++E9Wib6hUdQ= +github.com/IBM/sarama v1.43.0 h1:YFFDn8mMI2QL0wOrG0J2sFoVIAFl7hS9JQi2YZsXtJc= +github.com/IBM/sarama v1.43.0/go.mod h1:zlE6HEbC/SMQ9mhEYaF7nNLYOUyrs0obySKCckWP9BM= github.com/Rican7/retry v0.3.1 h1:scY4IbO8swckzoA/11HgBwaZRJEyY9vaNJshcdhp1Mc= github.com/Rican7/retry v0.3.1/go.mod h1:CxSDrhAyXmTMeEuRAnArMu1FHu48vtfjLREWqVl7Vw0= github.com/benbjohnson/clock v1.3.5 h1:VvXlSJBzZpA/zum6Sj74hxwYI2DIxRWuNIoXAzHZz5o= github.com/benbjohnson/clock v1.3.5/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/bufbuild/protocompile v0.7.1 h1:Kd8fb6EshOHXNNRtYAmLAwy/PotlyFoN0iMbuwGNh0M= github.com/bufbuild/protocompile v0.7.1/go.mod h1:+Etjg4guZoAqzVk2czwEQP12yaxLJ8DxuqCJ9qHdH94= +github.com/bufbuild/protocompile v0.9.0 h1:DI8qLG5PEO0Mu1Oj51YFPqtx6I3qYXUAhJVJ/IzAVl0= +github.com/bufbuild/protocompile v0.9.0/go.mod h1:s89m1O8CqSYpyE/YaSGtg1r1YFMF5nLTwh4vlj6O444= github.com/cpuguy83/go-md2man/v2 v2.0.3 h1:qMCsGGgs+MAzDFyp9LpAe1Lqy/fY/qCovCm0qnXZOBM= github.com/cpuguy83/go-md2man/v2 v2.0.3/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -14,6 +18,8 @@ github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/eapache/go-resiliency v1.5.0 h1:dRsaR00whmQD+SgVKlq/vCRFNgtEb5yppyeVos3Yce0= github.com/eapache/go-resiliency v1.5.0/go.mod h1:5yPzW0MIvSe0JDsv0v+DvcjEv2FyD6iZYSs1ZI+iQho= +github.com/eapache/go-resiliency v1.6.0 h1:CqGDTLtpwuWKn6Nj3uNUdflaq+/kIPsg0gfNzHton30= +github.com/eapache/go-resiliency v1.6.0/go.mod h1:5yPzW0MIvSe0JDsv0v+DvcjEv2FyD6iZYSs1ZI+iQho= github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 h1:Oy0F4ALJ04o5Qqpdz8XLIpNA3WM/iSIXqxtqo7UGVws= github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3/go.mod h1:YvSRo5mw33fLEx1+DlK6L2VV43tJt5Eyel9n9XBcR+0= github.com/eapache/queue v1.1.0 h1:YOEu7KNc61ntiQlcEeUIoDTJ2o8mQznoNvUhiigpIqc= @@ -21,6 +27,8 @@ github.com/eapache/queue v1.1.0/go.mod h1:6eCeP0CKFpHLu8blIFXhExK/dRa7WDZfr6jVFP github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk= github.com/fatih/color v1.14.1 h1:qfhVLaG5s+nCROl1zJsZRxFeYrHLqWroPOQ8BWiNb4w= github.com/fatih/color v1.14.1/go.mod h1:2oHN61fhTpgcxD3TSWCgKDiH1+x4OiDVVGH8WlgGZGg= +github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM= +github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE= github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw= github.com/fortytw2/leaktest v1.3.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g= github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8= @@ -30,6 +38,8 @@ github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyT github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= +github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= +github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= @@ -43,6 +53,8 @@ github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY github.com/hashicorp/errwrap v1.1.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4= github.com/hashicorp/go-hclog v1.5.0 h1:bI2ocEMgcVlz55Oj1xZNBsVi900c7II+fWDyV9o+13c= github.com/hashicorp/go-hclog v1.5.0/go.mod h1:W4Qnvbt70Wk/zYJryRzDRU/4r0kIg0PVHBcfoyhpF5M= +github.com/hashicorp/go-hclog v1.6.2 h1:NOtoftovWkDheyUM/8JW3QMiXyxJK3uHRK7wV04nD2I= +github.com/hashicorp/go-hclog v1.6.2/go.mod h1:W4Qnvbt70Wk/zYJryRzDRU/4r0kIg0PVHBcfoyhpF5M= github.com/hashicorp/go-multierror v1.1.1 h1:H5DkEtf6CXdFp0N0Em5UCwQpXMWke8IA0+lD48awMYo= github.com/hashicorp/go-multierror v1.1.1/go.mod h1:iw975J/qwKPdAO1clOe2L8331t/9/fmwbPZ6JB6eMoM= github.com/hashicorp/go-plugin v1.6.0 h1:wgd4KxHJTVGGqWBq4QPB1i5BZNEx9BR8+OFmHDmTk8A= @@ -70,8 +82,12 @@ github.com/jcmturner/rpc/v2 v2.0.3 h1:7FXXj8Ti1IaVFpSAziCZWNzbNuZmnvw/i6CqLNdWfZ github.com/jcmturner/rpc/v2 v2.0.3/go.mod h1:VUJYCIDm3PVOEHw8sgt091/20OJjskO/YJki3ELg/Hc= github.com/jhump/protoreflect v1.15.4 h1:mrwJhfQGGljwvR/jPEocli8KA6G9afbQpH8NY2wORcI= github.com/jhump/protoreflect v1.15.4/go.mod h1:2B+zwrnMY3TTIqEK01OG/d3pyUycQBfDf+bx8fE2DNg= +github.com/jhump/protoreflect v1.15.6 h1:WMYJbw2Wo+KOWwZFvgY0jMoVHM6i4XIvRs2RcBj5VmI= +github.com/jhump/protoreflect v1.15.6/go.mod h1:jCHoyYQIJnaabEYnbGwyo9hUqfyUMTbJw/tAut5t97E= github.com/klauspost/compress v1.17.4 h1:Ej5ixsIri7BrIjBkRZLTo6ghwrEtHFk7ijlczPW4fZ4= github.com/klauspost/compress v1.17.4/go.mod h1:/dCuZOvVtNoHsyb+cuJD3itjs3NbnF6KH9zAO4BDxPM= +github.com/klauspost/compress v1.17.7 h1:ehO88t2UGzQK66LMdE8tibEd1ErmzZjNEqWkjLAKQQg= +github.com/klauspost/compress v1.17.7/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= @@ -94,12 +110,18 @@ github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27k github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= github.com/mattn/go-isatty v0.0.17 h1:BTarxUcIeDqL27Mc+vyvdWYSL28zpIhv3RoTdsLMPng= github.com/mattn/go-isatty v0.0.17/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77 h1:7GoSOOW2jpsfkntVKaS2rAr1TJqfcxotyaUcuxoZSzg= github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77/go.mod h1:kRemZodwjscx+RGhAo8eIhFbs2+BFgRtFPeD/KE+zxI= +github.com/mitchellh/go-testing-interface v1.14.1 h1:jrgshOhYAUVNMAJiKbEu7EqAwgJJ2JqpQmpLJOu07cU= +github.com/mitchellh/go-testing-interface v1.14.1/go.mod h1:gfgS7OtZj6MA4U1UrDRp04twqAjfvlZyCfX3sDjEym8= github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY= github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo= github.com/oklog/run v1.0.0 h1:Ru7dDtJNOyC66gQ5dQmaCa0qIsAUFY3sFpK1Xk8igrw= github.com/oklog/run v1.0.0/go.mod h1:dlhp/R75TPv97u0XWUtDeV/lRKWPKSdTuV0TZvrmrQA= +github.com/oklog/run v1.1.0 h1:GEenZ1cK0+q0+wsJew9qUg/DyD8k3JzYsZAi5gYi2mA= +github.com/oklog/run v1.1.0/go.mod h1:sVPdnTZT1zYwAJeCMu2Th4T21pA3FPOQRfWjQlk7DVU= github.com/pelletier/go-toml/v2 v2.1.1 h1:LWAJwfNvjQZCFIDKWYQaM62NcYeYViCmWIwmOStowAI= github.com/pelletier/go-toml/v2 v2.1.1/go.mod h1:tJU2Z3ZkXwnxa4DPO899bsyIoywizdUvyaeZurnPPDc= github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ= @@ -157,13 +179,19 @@ go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0= go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= go.uber.org/ratelimit v0.3.0 h1:IdZd9wqvFXnvLvSEBo0KPcGfkoBGNkpTHlrE3Rcjkjw= go.uber.org/ratelimit v0.3.0/go.mod h1:So5LG7CV1zWpY1sHe+DXTJqQvOx+FFPFaAs2SnoyBaI= +go.uber.org/ratelimit v0.3.1 h1:K4qVE+byfv/B3tC+4nYWP7v/6SimcO7HzHekoMNBma0= +go.uber.org/ratelimit v0.3.1/go.mod h1:6euWsTB6U/Nb3X++xEUXA8ciPJvr19Q/0h1+oDcJhRk= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= golang.org/x/crypto v0.6.0/go.mod h1:OFC/31mSvZgRz0V1QTNCzfAI1aIRzbiufJtkMIlEp58= golang.org/x/crypto v0.18.0 h1:PGVlW0xEltQnzFZ55hkuX5+KLyrMYhHld1YHO4AKcdc= golang.org/x/crypto v0.18.0/go.mod h1:R0j02AL6hcrfOiy9T4ZYp/rcWeMxM3L6QYxlOuEG1mg= +golang.org/x/crypto v0.21.0 h1:X31++rzVUdKhX5sWmSOFZxx8UW/ldWx55cbf08iNAMA= +golang.org/x/crypto v0.21.0/go.mod h1:0BP7YvVV9gBbVKyeTG0Gyn+gZm94bibOW5BjDEYAOMs= golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 h1:hNQpMuAJe5CtcUqCXaWga3FHu+kQvCqcsoVaQgSV60o= golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3/go.mod h1:idGWGoKP1toJGkd5/ig9ZLuPcZBC3ewk7SzmH0uou08= +golang.org/x/exp v0.0.0-20240222234643-814bf88cf225 h1:LfspQV/FYTatPTr/3HzIcmiUFH7PGP+OQ6mgDYo3yuQ= +golang.org/x/exp v0.0.0-20240222234643-814bf88cf225/go.mod h1:CxmFvTBINI24O/j8iY7H1xHzx2i4OsyguNBmN/uPtqc= golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200114155413-6afb5195e5aa/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= @@ -173,6 +201,8 @@ golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/net v0.20.0 h1:aCL9BSgETF1k+blQaYUBx9hJ9LOGP3gAVemcZlf1Kpo= golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY= +golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc= +golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.6.0 h1:5BMeUDZ7vkXGfEr1x9B4bRcTH4lpkTkpdh0T/J+qjbQ= @@ -189,8 +219,11 @@ golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.16.0 h1:xWw16ngr6ZMtmxDyKyIgsE93KNKz5HKmMa3b8ALHidU= golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4= +golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= @@ -208,12 +241,18 @@ golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8T golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac h1:nUQEQmH/csSvFECKYRv6HWEyypysidKl2I6Qpsglq/0= google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:daQN87bsDqDoe316QbbvX60nMoJQa4r6Ds0ZuoAe5yA= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240304212257-790db918fca8 h1:IR+hp6ypxjH24bkMfEJ0yHR21+gwPWdV+/IBrPQyn3k= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240304212257-790db918fca8/go.mod h1:UCOku4NytXMJuLQE5VuqA5lX3PcHCBo8pxNyvkf4xBs= google.golang.org/grpc v1.60.1 h1:26+wFr+cNqSGFcOXcabYC0lUVJVRa2Sb2ortSK7VrEU= google.golang.org/grpc v1.60.1/go.mod h1:OlCHIeLYqSSsLi6i49B5QGdzaMZK9+M7LXN2FKz4eGM= +google.golang.org/grpc v1.62.1 h1:B4n+nfKzOICUXMgyrNd19h/I9oH0L1pizfk1d4zSgTk= +google.golang.org/grpc v1.62.1/go.mod h1:IWTG0VlJLCh1SkC58F7np9ka9mx/WNkjl4PGJaiq+QE= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= google.golang.org/protobuf v1.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I= google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= +google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI= +google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= diff --git a/internal/acl/acl-operation.go b/internal/acl/acl-operation.go index 304758ca..656413e6 100644 --- a/internal/acl/acl-operation.go +++ b/internal/acl/acl-operation.go @@ -2,8 +2,8 @@ package acl import ( "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/internal/acl/type-formatter.go b/internal/acl/type-formatter.go index ca28648c..6e25e07d 100644 --- a/internal/acl/type-formatter.go +++ b/internal/acl/type-formatter.go @@ -4,7 +4,7 @@ import ( "strings" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" ) diff --git a/internal/auth/token-provider.go b/internal/auth/token-provider.go index c062dbce..89695ede 100644 --- a/internal/auth/token-provider.go +++ b/internal/auth/token-provider.go @@ -2,8 +2,8 @@ package auth import ( "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/pkg/plugins" - "github.com/deviceinsight/kafkactl/pkg/plugins/auth" + "github.com/deviceinsight/kafkactl/v5/pkg/plugins" + "github.com/deviceinsight/kafkactl/v5/pkg/plugins/auth" ) var loadedPlugins = make(map[string]auth.AccessTokenProvider) diff --git a/internal/broker/broker-operation.go b/internal/broker/broker-operation.go index e2e3bfc5..74e5aa94 100644 --- a/internal/broker/broker-operation.go +++ b/internal/broker/broker-operation.go @@ -8,8 +8,8 @@ import ( "gopkg.in/yaml.v2" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/internal/common-operation.go b/internal/common-operation.go index e6728703..577bb0cc 100644 --- a/internal/common-operation.go +++ b/internal/common-operation.go @@ -10,16 +10,16 @@ import ( "strings" "time" - "github.com/deviceinsight/kafkactl/internal/auth" + "github.com/deviceinsight/kafkactl/v5/internal/auth" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/internal/helpers/avro" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/avro" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/helpers" - "github.com/deviceinsight/kafkactl/internal/helpers/protobuf" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/helpers" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/protobuf" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/viper" ) diff --git a/internal/consume/AvroMessageDeserializer.go b/internal/consume/AvroMessageDeserializer.go index fd77b2d2..041e2fee 100644 --- a/internal/consume/AvroMessageDeserializer.go +++ b/internal/consume/AvroMessageDeserializer.go @@ -6,11 +6,11 @@ import ( "strings" "time" - "github.com/deviceinsight/kafkactl/internal/helpers/avro" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/avro" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/linkedin/goavro/v2" "github.com/pkg/errors" ) diff --git a/internal/consume/DefaultMessageDeserializer.go b/internal/consume/DefaultMessageDeserializer.go index 6a73234b..774814fb 100644 --- a/internal/consume/DefaultMessageDeserializer.go +++ b/internal/consume/DefaultMessageDeserializer.go @@ -6,7 +6,7 @@ import ( "time" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" ) type DefaultMessageDeserializer struct { diff --git a/internal/consume/GroupConsumer.go b/internal/consume/GroupConsumer.go index ae31aecf..ef79c51e 100644 --- a/internal/consume/GroupConsumer.go +++ b/internal/consume/GroupConsumer.go @@ -4,7 +4,7 @@ import ( "context" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "golang.org/x/sync/errgroup" ) diff --git a/internal/consume/PartitionConsumer.go b/internal/consume/PartitionConsumer.go index 5e0cd7c7..401fb63e 100644 --- a/internal/consume/PartitionConsumer.go +++ b/internal/consume/PartitionConsumer.go @@ -6,8 +6,8 @@ import ( "time" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" "golang.org/x/sync/errgroup" ) diff --git a/internal/consume/ProtobufMessageDeserializer.go b/internal/consume/ProtobufMessageDeserializer.go index 39c4bff0..93cac2c0 100644 --- a/internal/consume/ProtobufMessageDeserializer.go +++ b/internal/consume/ProtobufMessageDeserializer.go @@ -6,8 +6,8 @@ import ( "time" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/helpers/protobuf" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/protobuf" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/jhump/protoreflect/desc" "github.com/jhump/protoreflect/dynamic" "github.com/pkg/errors" diff --git a/internal/consume/consume-operation.go b/internal/consume/consume-operation.go index d0399faf..5cccd986 100644 --- a/internal/consume/consume-operation.go +++ b/internal/consume/consume-operation.go @@ -6,13 +6,13 @@ import ( "strings" "time" - "github.com/deviceinsight/kafkactl/internal/helpers" + "github.com/deviceinsight/kafkactl/v5/internal/helpers" "golang.org/x/sync/errgroup" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" ) diff --git a/internal/consumergroupoffsets/OffsetResettingConsumer.go b/internal/consumergroupoffsets/OffsetResettingConsumer.go index 50ef1029..ed85c443 100644 --- a/internal/consumergroupoffsets/OffsetResettingConsumer.go +++ b/internal/consumergroupoffsets/OffsetResettingConsumer.go @@ -4,8 +4,8 @@ import ( "strconv" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/consume" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/consume" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" ) diff --git a/internal/consumergroupoffsets/consumer-group-offset-operation.go b/internal/consumergroupoffsets/consumer-group-offset-operation.go index 8ef3a90c..749bfac2 100644 --- a/internal/consumergroupoffsets/consumer-group-offset-operation.go +++ b/internal/consumergroupoffsets/consumer-group-offset-operation.go @@ -1,13 +1,13 @@ package consumergroupoffsets import ( - "github.com/deviceinsight/kafkactl/internal/helpers" + "github.com/deviceinsight/kafkactl/v5/internal/helpers" "golang.org/x/sync/errgroup" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" ) diff --git a/internal/consumergroups/consumer-group-operation.go b/internal/consumergroups/consumer-group-operation.go index fdb4c082..61f99fb0 100644 --- a/internal/consumergroups/consumer-group-operation.go +++ b/internal/consumergroups/consumer-group-operation.go @@ -7,9 +7,9 @@ import ( "strings" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/internal/docs-operation.go b/internal/docs-operation.go index 5d72b637..c722cf55 100644 --- a/internal/docs-operation.go +++ b/internal/docs-operation.go @@ -8,7 +8,7 @@ import ( "sort" "strings" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" "github.com/spf13/cobra/doc" diff --git a/internal/global/config.go b/internal/global/config.go index 47e3d44b..2e6a7926 100644 --- a/internal/global/config.go +++ b/internal/global/config.go @@ -6,7 +6,7 @@ import ( "path/filepath" "strings" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/spf13/viper" ) diff --git a/internal/helpers/TerminalContext.go b/internal/helpers/TerminalContext.go index c9bc340c..c0749982 100644 --- a/internal/helpers/TerminalContext.go +++ b/internal/helpers/TerminalContext.go @@ -5,7 +5,7 @@ import ( "os" "os/signal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" ) func CreateTerminalContext() context.Context { diff --git a/internal/helpers/avro/JsonCodec.go b/internal/helpers/avro/JsonCodec.go index cd5bfbfa..39cfdbeb 100644 --- a/internal/helpers/avro/JsonCodec.go +++ b/internal/helpers/avro/JsonCodec.go @@ -3,7 +3,7 @@ package avro import ( "strings" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" ) type JSONCodec int diff --git a/internal/helpers/protobuf/protobuf.go b/internal/helpers/protobuf/protobuf.go index 26a25d60..85eed834 100644 --- a/internal/helpers/protobuf/protobuf.go +++ b/internal/helpers/protobuf/protobuf.go @@ -7,7 +7,7 @@ import ( "google.golang.org/protobuf/proto" "google.golang.org/protobuf/types/descriptorpb" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/jhump/protoreflect/desc" "github.com/jhump/protoreflect/desc/protoparse" ) diff --git a/internal/k8s/executer_test.go b/internal/k8s/executer_test.go index e8164160..16d8945a 100644 --- a/internal/k8s/executer_test.go +++ b/internal/k8s/executer_test.go @@ -5,10 +5,10 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" ) type TestRunner struct { diff --git a/internal/k8s/executor.go b/internal/k8s/executor.go index 801c788e..c3ccc0f0 100644 --- a/internal/k8s/executor.go +++ b/internal/k8s/executor.go @@ -10,8 +10,8 @@ import ( "github.com/pkg/errors" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" ) type Version struct { diff --git a/internal/k8s/k8s-operation.go b/internal/k8s/k8s-operation.go index a936217e..87622ed4 100644 --- a/internal/k8s/k8s-operation.go +++ b/internal/k8s/k8s-operation.go @@ -5,10 +5,10 @@ import ( "fmt" "strings" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" "github.com/spf13/pflag" diff --git a/internal/k8s/k8s-operation_test.go b/internal/k8s/k8s-operation_test.go index d5d9564a..5654e338 100644 --- a/internal/k8s/k8s-operation_test.go +++ b/internal/k8s/k8s-operation_test.go @@ -5,14 +5,14 @@ import ( "testing" "time" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" - "github.com/deviceinsight/kafkactl/internal/helpers/avro" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/avro" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/k8s" - "github.com/deviceinsight/kafkactl/internal/testutil" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/k8s" + "github.com/deviceinsight/kafkactl/v5/internal/testutil" ) func TestAllAvailableEnvironmentVariablesAreParsed(t *testing.T) { diff --git a/internal/k8s/runner.go b/internal/k8s/runner.go index 92507c5c..6be1525b 100644 --- a/internal/k8s/runner.go +++ b/internal/k8s/runner.go @@ -9,7 +9,7 @@ import ( "sync" "syscall" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" ) diff --git a/internal/partition/partition-operation.go b/internal/partition/partition-operation.go index 82c630e9..a80794f2 100644 --- a/internal/partition/partition-operation.go +++ b/internal/partition/partition-operation.go @@ -8,8 +8,8 @@ import ( "time" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/pkg/errors" "github.com/spf13/cobra" ) diff --git a/internal/producer/AvroMessageSerializer.go b/internal/producer/AvroMessageSerializer.go index d98bcbf1..eb3cbacf 100644 --- a/internal/producer/AvroMessageSerializer.go +++ b/internal/producer/AvroMessageSerializer.go @@ -3,10 +3,10 @@ package producer import ( "encoding/binary" - "github.com/deviceinsight/kafkactl/internal/helpers/avro" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/avro" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/util" schemaregistry "github.com/landoop/schema-registry" "github.com/linkedin/goavro/v2" "github.com/pkg/errors" diff --git a/internal/producer/ProtobufMessageSerializer.go b/internal/producer/ProtobufMessageSerializer.go index c3e807fc..b4321ed8 100644 --- a/internal/producer/ProtobufMessageSerializer.go +++ b/internal/producer/ProtobufMessageSerializer.go @@ -2,7 +2,7 @@ package producer import ( "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal/helpers/protobuf" + "github.com/deviceinsight/kafkactl/v5/internal/helpers/protobuf" "github.com/golang/protobuf/jsonpb" "github.com/jhump/protoreflect/desc" "github.com/jhump/protoreflect/dynamic" diff --git a/internal/producer/input/csv_parser.go b/internal/producer/input/csv_parser.go index 546cbf39..517e81ed 100644 --- a/internal/producer/input/csv_parser.go +++ b/internal/producer/input/csv_parser.go @@ -5,8 +5,8 @@ import ( "strings" "time" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" ) diff --git a/internal/producer/producer-operation.go b/internal/producer/producer-operation.go index 88024ca8..c702307d 100644 --- a/internal/producer/producer-operation.go +++ b/internal/producer/producer-operation.go @@ -9,10 +9,10 @@ import ( "syscall" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/producer/input" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/producer/input" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" "go.uber.org/ratelimit" ) diff --git a/internal/testutil/helpers.go b/internal/testutil/helpers.go index a13a2ea3..1e3f4a3b 100644 --- a/internal/testutil/helpers.go +++ b/internal/testutil/helpers.go @@ -12,7 +12,7 @@ import ( "github.com/Rican7/retry" "github.com/Rican7/retry/backoff" "github.com/Rican7/retry/strategy" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/util" schemaregistry "github.com/landoop/schema-registry" ) diff --git a/internal/testutil/test_util.go b/internal/testutil/test_util.go index 606dc038..c7edbb5c 100644 --- a/internal/testutil/test_util.go +++ b/internal/testutil/test_util.go @@ -13,13 +13,13 @@ import ( "testing" "time" - "github.com/deviceinsight/kafkactl/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/global" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/cmd" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/cmd" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/spf13/cobra" ) diff --git a/internal/topic/topic-operation.go b/internal/topic/topic-operation.go index c9bc8971..97eb02f7 100644 --- a/internal/topic/topic-operation.go +++ b/internal/topic/topic-operation.go @@ -8,9 +8,9 @@ import ( "time" "github.com/IBM/sarama" - "github.com/deviceinsight/kafkactl/internal" - "github.com/deviceinsight/kafkactl/internal/output" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal" + "github.com/deviceinsight/kafkactl/v5/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/util" "github.com/pkg/errors" "github.com/spf13/cobra" "gopkg.in/yaml.v2" diff --git a/internal/util/parse_offsets_test.go b/internal/util/parse_offsets_test.go index f25cb0f3..c2e51752 100644 --- a/internal/util/parse_offsets_test.go +++ b/internal/util/parse_offsets_test.go @@ -5,7 +5,7 @@ import ( "strings" "testing" - "github.com/deviceinsight/kafkactl/internal/util" + "github.com/deviceinsight/kafkactl/v5/internal/util" ) func TestParseOffsets(t *testing.T) { diff --git a/main.go b/main.go index 96313c97..36f0a064 100644 --- a/main.go +++ b/main.go @@ -17,8 +17,8 @@ package main import ( "os" - "github.com/deviceinsight/kafkactl/cmd" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/cmd" + "github.com/deviceinsight/kafkactl/v5/internal/output" ) func main() { diff --git a/pkg/plugins/auth/interface.go b/pkg/plugins/auth/interface.go index c6b8de5f..ccd781fd 100644 --- a/pkg/plugins/auth/interface.go +++ b/pkg/plugins/auth/interface.go @@ -1,7 +1,7 @@ package auth import ( - "github.com/deviceinsight/kafkactl/pkg/plugins" + "github.com/deviceinsight/kafkactl/v5/pkg/plugins" "github.com/hashicorp/go-plugin" ) diff --git a/pkg/plugins/plugin.go b/pkg/plugins/plugin.go index 945ff095..009048d1 100644 --- a/pkg/plugins/plugin.go +++ b/pkg/plugins/plugin.go @@ -7,8 +7,8 @@ import ( "path/filepath" "runtime" - "github.com/deviceinsight/kafkactl/internal/global" - "github.com/deviceinsight/kafkactl/internal/output" + "github.com/deviceinsight/kafkactl/v5/internal/global" + "github.com/deviceinsight/kafkactl/v5/internal/output" "github.com/hashicorp/go-hclog" "github.com/hashicorp/go-plugin" "github.com/pkg/errors"