CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test: do not have leadership election during kafka test (#11404)

This commit is contained in:
Joshua Powers 2022-07-14 11:07:34 -06:00 committed by GitHub
parent 2d357d464b
commit acc8008fb2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/outputs/kafka/kafka_test.go
View File

@ -61,9 +61,10 @@ func TestConnectAndWriteIntegration(t *testing.T) {
"KAFKA_ADVERTISED_HOST_NAME": "localhost", "KAFKA_ADVERTISED_HOST_NAME": "localhost",
"KAFKA_ADVERTISED_PORT": "9092", "KAFKA_ADVERTISED_PORT": "9092",
"KAFKA_ZOOKEEPER_CONNECT": fmt.Sprintf("telegraf-test-zookeeper:%s", zookeeper.Ports["2181"]), "KAFKA_ZOOKEEPER_CONNECT": fmt.Sprintf("telegraf-test-zookeeper:%s", zookeeper.Ports["2181"]),
"KAFKA_CREATE_TOPICS": "Test:1:1",
}, },
Networks: []string{networkName}, Networks: []string{networkName},
WaitingFor: wait.ForLog("[KafkaServer id=1001] started"), WaitingFor: wait.ForLog("Log loaded for partition Test-0 with initial high watermark 0"),
} }
err = container.Start() err = container.Start()
require.NoError(t, err, "failed to start container") require.NoError(t, err, "failed to start container")
@ -92,7 +93,8 @@ func TestConnectAndWriteIntegration(t *testing.T) {
// Verify that we can successfully write data to the kafka broker // Verify that we can successfully write data to the kafka broker
err = k.Write(testutil.MockMetrics()) err = k.Write(testutil.MockMetrics())
require.NoError(t, err) require.NoError(t, err)
k.Close() err = k.Close()
require.NoError(t, err)
} }
func TestTopicSuffixes(t *testing.T) { func TestTopicSuffixes(t *testing.T) {