Skip to content

Commit

Permalink
Skip redpanda.remote. when migrating Kafka topic properties
Browse files Browse the repository at this point in the history
Signed-off-by: Mihai Todor <[email protected]>
  • Loading branch information
mihaitodor committed Feb 26, 2025
1 parent b720a03 commit 840ed26
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions internal/impl/kafka/enterprise/topic_crud.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ import (
"context"
"errors"
"fmt"
"strings"

"github.com/twmb/franz-go/pkg/kadm"
"github.com/twmb/franz-go/pkg/kerr"
Expand Down Expand Up @@ -83,8 +82,7 @@ func createTopic(ctx context.Context, topic string, replicationFactorOverride bo
c.Key == "max.message.bytes" ||
c.Key == "replication.factor" ||
c.Key == "write.caching" ||
c.Key == "redpanda.iceberg.mode" ||
strings.HasPrefix(c.Key, "redpanda.remote.") {
c.Key == "redpanda.iceberg.mode" {

destinationConfigs[c.Key] = c.Value
}
Expand Down

0 comments on commit 840ed26

Please sign in to comment.