diff --git a/lib/debezium/keys.go b/lib/debezium/keys.go index 4f5f393be..840e95ae2 100644 --- a/lib/debezium/keys.go +++ b/lib/debezium/keys.go @@ -53,7 +53,6 @@ func ParsePartitionKey(key []byte, cdcKeyFormat string) (map[string]any, error) return parsePartitionKeyStruct(key) case kafkalib.StringKeyFmt: return parsePartitionKeyString(key) - } return nil, fmt.Errorf("format: %s is not supported", cdcKeyFormat) }