From c2105e3199ee2a10418580f6b4bc9d05bb4b6c3c Mon Sep 17 00:00:00 2001 From: Travis Turner Date: Fri, 3 Mar 2023 17:25:29 -0600 Subject: [PATCH] remove kafkaRunner (no longer used) --- cli/cli.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/cli/cli.go b/cli/cli.go index 1bba59cea..9d251ac7c 100644 --- a/cli/cli.go +++ b/cli/cli.go @@ -15,7 +15,6 @@ import ( featurebase "github.com/featurebasedb/featurebase/v3" "github.com/featurebasedb/featurebase/v3/cli/batch" "github.com/featurebasedb/featurebase/v3/cli/fbcloud" - "github.com/featurebasedb/featurebase/v3/cli/kafka" "github.com/featurebasedb/featurebase/v3/errors" "github.com/featurebasedb/featurebase/v3/logger" ) @@ -88,10 +87,6 @@ type Command struct { // `-c` flag in the command line. nonInteractiveMode bool - // kafkaRunner will be non-nil if the CLI has been configured to consume - // from kafka. In that case, Command will run in non-interactive mode. - kafkaRunner *kafka.Runner - // quit gets closed when Run should stop listening for input. quit chan struct{} }