Remove topic filter log

This won't work until data is actually fetched... Signed-off-by: Mihai Todor <[email protected]>
redpanda-data · Jan 14, 2025 · 0ce0e32 · 0ce0e32
1 parent 6dad989
commit 0ce0e32
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 14 deletions.
diff --git a/internal/impl/kafka/franz_reader_ordered.go b/internal/impl/kafka/franz_reader_ordered.go
@@ -411,13 +411,6 @@ func (f *FranzReaderOrdered) Connect(ctx context.Context) error {
 		return fmt.Errorf("failed to connect to cluster: %s", err)
 	}
 
-	topics := f.Client.GetConsumeTopics()
-	if len(topics) > 0 {
-		f.log.Debugf("Consuming from topics: %s", topics)
-	} else {
-		f.log.Warn("Topic filter did not match any existing topics")
-	}
-
 	if f.lagUpdater != nil {
 		f.lagUpdater.Stop()
 	}

diff --git a/internal/impl/kafka/franz_reader_unordered.go b/internal/impl/kafka/franz_reader_unordered.go
@@ -497,13 +497,6 @@ func (f *FranzReaderUnordered) Connect(ctx context.Context) error {
 		return fmt.Errorf("failed to connect to cluster: %s", err)
 	}
 
-	topics := cl.GetConsumeTopics()
-	if len(topics) > 0 {
-		f.log.Debugf("Consuming from topics: %s", topics)
-	} else {
-		f.log.Warn("Topic filter did not match any existing topics")
-	}
-
 	go func() {
 		defer func() {
 			cl.Close()