Skip to content

Commit

Permalink
rename var
Browse files Browse the repository at this point in the history
  • Loading branch information
d-rk committed Nov 10, 2023
1 parent 4ad9f41 commit 6685de3
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cmd/reset/reset-consumer-group-offset_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ func TestResetCGOToDatetimeIntegration(t *testing.T) {
time.Sleep(1 * time.Millisecond) // need to have messaged produced at different milliseconds to have reproducible test

t1 := time.Now()
t2 := t1.Format("2006-01-02T15:04:05.000Z")
t1Formatted := t1.Format("2006-01-02T15:04:05.000Z")

testutil.ProduceMessage(t, topicName, "test-key", "c", 0, 2)
testutil.ProduceMessage(t, topicName, "test-key", "d", 0, 3)
Expand All @@ -157,7 +157,7 @@ func TestResetCGOToDatetimeIntegration(t *testing.T) {
//test with --to-datetime
kafkaCtl := testutil.CreateKafkaCtlCommand()

if _, err := kafkaCtl.Execute("reset", "offset", group, "--topic", topicName, "--to-datetime", t2, "--execute"); err != nil {
if _, err := kafkaCtl.Execute("reset", "offset", group, "--topic", topicName, "--to-datetime", t1Formatted, "--execute"); err != nil {
t.Fatalf("failed to execute command: %v", err)
}

Expand Down

0 comments on commit 6685de3

Please sign in to comment.