Skip to content

Commit

Permalink
fix make fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
3AceShowHand committed Nov 10, 2023
1 parent 0ab2464 commit 368b039
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions cdc/sinkv2/util/helper_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,9 @@ import (
"testing"

"github.com/Shopify/sarama"
"github.com/pingcap/tiflow/cdc/sink/mq/producer/kafka"
pkafka "github.com/pingcap/tiflow/pkg/sink/kafka"
"github.com/stretchr/testify/require"

"github.com/pingcap/tiflow/cdc/sink/mq/producer/kafka"
)

func TestPartition(t *testing.T) {
Expand Down Expand Up @@ -54,7 +53,7 @@ func TestPartition(t *testing.T) {

// assume a topic already exist, the not default topic won't be affected by the default topic's partition number.
err = adminClient.CreateTopic("new-topic-2", &sarama.TopicDetail{

NumPartitions: 3,
}, false)
require.NoError(t, err)
Expand Down

0 comments on commit 368b039

Please sign in to comment.