Skip to content

[automation] Update go release version 1.18.4#32493

Closed
ghost wants to merge 3 commits intomainfrom
update-go-version-20220725210948-main
Closed

[automation] Update go release version 1.18.4#32493
ghost wants to merge 3 commits intomainfrom
update-go-version-20220725210948-main

Conversation

@ghost
Copy link

@ghost ghost commented Jul 25, 2022

What

Bump go release version with the latest release.

Further details

See changelog for 1.18.4

It requires the version to be bumped first in golang-crossbuild project, then a new release will be added to https://github.com/elastic/golang-crossbuild/releases. Otherwise it will fail until the docker images are available.

Automatically generated from https://apm-ci.elastic.co/job/apm-shared/job/bump-go-release-version-pipeline/

@ghost ghost requested review from a team as code owners July 25, 2022 21:09
@ghost ghost added the automation label Jul 25, 2022
@ghost ghost removed their request for review July 25, 2022 21:09
@ghost ghost added backport-skip Skip notification from the automated backport with mergify dependency labels Jul 25, 2022
@ghost ghost requested review from faec and fearful-symmetry July 25, 2022 21:09
@botelastic botelastic bot added the needs_team Indicates that the issue/PR needs a Team:* label label Jul 25, 2022
@mergify mergify bot assigned ghost Jul 25, 2022
@elasticmachine
Copy link
Contributor

elasticmachine commented Jul 25, 2022

💔 Tests Failed

the below badges are clickable and redirect to their specific view in the CI or DOCS
Pipeline View Test View Changes Artifacts preview preview

Expand to view the summary

Build stats

  • Start Time: 2022-07-25T21:10:11.546+0000

  • Duration: 116 min 38 sec

Test stats 🧪

Test Results
Failed 14
Passed 22521
Skipped 1937
Total 24472

Test errors 14

Expand to view the tests failures

> Show only the first 10 test failures

Build&Test / filebeat-goIntegTest / TestSASLAuthentication – github.com/elastic/beats/v7/filebeat/input/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestSASLAuthentication
    kafka_integration_test.go:396: timeout waiting for incoming events
--- FAIL: TestSASLAuthentication (30.29s)

Build&Test / libbeat-goIntegTest / TestKafkaPublish – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish
=== RUN   TestKafkaPublish/run_test(0):_publish_single_event_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.301Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.302Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.762Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(1):_publish_single_event_with_topic_from_type
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.165Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.468Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(2):_publish_single_event_with_formating_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.817Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.195Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.197Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.198Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(3):_batch_publish_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.200Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.200Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.749Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.752Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.763Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(4):_batch_publish_to_test_topic_from_type
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.763Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.793Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:28.115Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:28.115Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:28.115Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:28.115Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:28.115Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.458Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.458Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.476Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(5):_batch_publish_with_random_partitioner
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.476Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.477Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.628Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.018Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.018Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.019Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(6):_batch_publish_with_round_robin_partitioner
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.019Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.019Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.379Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:32.878Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:32.878Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:32.891Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(7):_batch_publish_with_hash_partitioner_without_key_(fallback_to_random)
{"log.level":"debug","@timestamp":"2022-07-25T22:33:32.903Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:32.904Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:33.169Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.580Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.580Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.586Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(8):_batch_publish_with_hash_partitioner_with_key
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.587Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.587Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.837Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(9):_batch_publish_with_fields_hash_partitioner
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.423Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:37.026Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.730Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.730Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.778Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(10):_publish_single_event_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.780Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.781Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:39.106Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.917Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.917Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.944Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}
=== RUN   TestKafkaPublish/run_test(11):_publish_single_event_to_test_topic_over_SASL/SCRAM
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.944Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"warn","@timestamp":"2022-07-25T22:33:40.945Z","log.logger":"cfgwarn","log.origin":{"file.name":"tlscommon/config.go","file.line":102},"message":"DEPRECATED: Treating the CommonName field on X.509 certificates as a host name when no Subject Alternative Names are present is going to be removed. Please update your certificates if needed. Will be removed in version: 8.0.0","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:41.078Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9093]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:43.134Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:43.134Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":406},"message":"Kafka publish failed with: kafka: client has run out of available brokers to talk to (Is your cluster reachable?)","ecs.version":"1.6.0"}
coverage: 73.4% of statements
panic: test timed out after 10m0s

goroutine 700 [running]:
testing.(*M).startAlarm.func1()
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:2029 +0x8e
created by time.goFunc
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/time/sleep.go:176 +0x32

goroutine 1 [chan receive, 9 minutes]:
testing.(*T).Run(0xc000348000, {0x127a082?, 0x9160a5?}, 0x12c9e30)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1487 +0x37a
testing.runTests.func1(0xc0002ee7b0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1839 +0x6e
testing.tRunner(0xc000348000, 0xc0002dfca0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1439 +0x102
testing.runTests(0xc0002314a0?, {0x1c33ce0, 0x5, 0x5}, {0x7f66ee9e4108?, 0x40?, 0x1c98da0?})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1837 +0x457
testing.(*M).Run(0xc0002314a0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1719 +0x5d9
main.main()
	_testmain.go:113 +0x255

goroutine 6 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc0001665b0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 7 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc000166680)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 8 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc000166750)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 9 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc000166820)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 10 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc0001668f0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 11 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc0001669c0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 12 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc000166a90)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 13 [chan receive, 9 minutes]:
github.com/klauspost/compress/zstd.(*blockDec).startDecoder(0xc000166b60)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:212 +0x94
created by github.com/klauspost/compress/zstd.newBlockDec
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/klauspost/compress@v1.13.6/zstd/blockdec.go:118 +0x165

goroutine 66 [chan receive, 9 minutes]:
testing.(*T).Run(0xc00037a680, {0xc0003b8300?, 0xc0005addd0?}, 0xc00007e820)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1487 +0x37a
github.com/elastic/beats/v7/libbeat/outputs/kafka.TestKafkaPublish(0xc00037a680?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:261 +0x255c
testing.tRunner(0xc00037a680, 0x12c9e30)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1439 +0x102
created by testing.(*T).Run
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1486 +0x35f

goroutine 714 [select, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic(0xc000d7e000, {0xc00003b340, 0x20}, 0x1, 0xc00034c6c0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:512 +0x4d3
github.com/elastic/beats/v7/libbeat/outputs/kafka.TestKafkaPublish.func1(0xc000d7e000)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:293 +0x4a5
testing.tRunner(0xc000d7e000, 0xc00007e820)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1439 +0x102
created by testing.(*T).Run
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/testing/testing.go:1486 +0x35f

goroutine 390 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x157d0?, {0x145b8b8, 0xc0009d20a0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 82 [chan receive]:
github.com/rcrowley/go-metrics.(*meterArbiter).tick(0x1c986e0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/rcrowley/go-metrics@v0.0.0-20201227073835-cf1acfcdf475/meter.go:239 +0x2a
created by github.com/rcrowley/go-metrics.NewMeter
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/rcrowley/go-metrics@v0.0.0-20201227073835-cf1acfcdf475/meter.go:46 +0xd3

goroutine 93 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x38b7d0?, {0x145b8b8, 0xc000118000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 189 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x72fd0?, {0x145b8b8, 0xc0001183c0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 724 [chan receive, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.(*client).errorWorker(0xc0005b0000, 0xc00090c808?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/client.go:269 +0x11d
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.(*client).Connect
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/client.go:133 +0x39b

goroutine 694 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*partitionConsumer).dispatcher(0xc00019e500)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:343 +0x3d
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:161 +0x2ca

goroutine 722 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*asyncProducer).retryHandler(0xc0001c64d0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:1038 +0x196
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.newAsyncProducer
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:167 +0x305

goroutine 192 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x777d0?, {0x145b8b8, 0xc000118460})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 323 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x0?, {0x145b8b8, 0xc00036e0a0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 120 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x0?, {0x145b8b8, 0xc00036e1e0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 96 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x73fd0?, {0x145b8b8, 0xc00019e000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 725 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*topicProducer).dispatch(0xc00034c700)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:412 +0x54
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*asyncProducer).newTopicProducer
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:407 +0x1f6

goroutine 225 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x3877d0?, {0x145b8b8, 0xc000464140})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 653 [select, 9 minutes]:
github.com/Shopify/sarama.(*client).backgroundMetadataUpdater(0xc000998000)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/client.go:823 +0x128
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.NewClient
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/client.go:184 +0x3d6

goroutine 222 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x52e7d0?, {0x145b8b8, 0xc000464000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 177 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x0?, {0x145b8b8, 0xc0001185a0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 723 [chan receive, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.(*client).successWorker(0xc05e66?, 0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/client.go:258 +0xe7
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.(*client).Connect
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/client.go:132 +0x31b

goroutine 350 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x131fd0?, {0x145b8b8, 0xc0005f4320})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 334 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x16fd0?, {0x145b8b8, 0xc0005f46e0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 693 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0xa2afd0?, {0x145b8b8, 0xc0009d2780})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 698 [chan receive]:
github.com/Shopify/sarama.(*partitionConsumer).responseFeeder(0xc0003f4000)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:463 +0x92
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:162 +0x345

goroutine 393 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x13fd0?, {0x145b8b8, 0xc0001f6000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 346 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x5d0fd0?, {0x145b8b8, 0xc00059c000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 353 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*asyncProducer).dispatcher(0xc0001c64d0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:330 +0xd1
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.newAsyncProducer
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/async_producer.go:166 +0x285

goroutine 266 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x386fd0?, {0x145b8b8, 0xc00019e140})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 758 [select, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x388fd0?, {0x145b8b8, 0xc00036e320})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 472 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x187d0?, {0x145b8b8, 0xc00036e140})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 316 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x177d0?, {0x145b8b8, 0xc0001f66e0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 308 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x38bfd0?, {0x145b8b8, 0xc00036e000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 326 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x530fd0?, {0x145b8b8, 0xc000aac000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 586 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x135fd0?, {0x145b8b8, 0xc0009d26e0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 699 [select, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x3897d0?, {0x145b8b8, 0xc0003f4000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 435 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0xa307d0?, {0x145b8b8, 0xc0003f4d20})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 580 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x134fd0?, {0x145b8b8, 0xc0005f40a0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 426 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x5d07d0?, {0x145b8b8, 0xc00036f220})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 438 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x106432a?, {0x145b8b8, 0xc0005f43c0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 352 [select, 9 minutes]:
github.com/Shopify/sarama.(*client).backgroundMetadataUpdater(0xc0001561b0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/client.go:823 +0x128
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.NewClient
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/client.go:184 +0x3d6

goroutine 696 [select, 9 minutes]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x52dfd0?, {0x145b8b8, 0xc00019e500})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 529 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x9b4d10?, {0x145b8b8, 0xc00036e280})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 363 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x0?, {0x145b8b8, 0xc0005f4000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 444 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0xa2c7d0?, {0x145b8b8, 0xc0004641e0})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 755 [chan receive]:
github.com/Shopify/sarama.(*partitionConsumer).responseFeeder(0xc00036e320)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:463 +0x92
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:162 +0x345

goroutine 447 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0xa2dfd0?, {0x145b8b8, 0xc0005f4280})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 697 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*partitionConsumer).dispatcher(0xc0003f4000)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:343 +0x3d
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:161 +0x2ca

goroutine 652 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*Broker).responseReceiver(0xc0003e4a80)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:892 +0x86
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*Broker).Open.func1
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:212 +0xb2b

goroutine 757 [select]:
github.com/Shopify/sarama.(*Broker).sendAndReceive(0xffffffffffffffff?, {0x145cad0, 0xc000440800}, {0x145cb18, 0xc000440840})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:820 +0x12c
github.com/Shopify/sarama.(*Broker).Fetch(0xc000957e28?, 0xc0000c3080?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:366 +0x4f
github.com/Shopify/sarama.(*brokerConsumer).fetchNewMessages(0xc00042c7d0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:948 +0x634
github.com/Shopify/sarama.(*brokerConsumer).subscriptionConsumer(0xc00042c7d0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:805 +0xe5
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).newBrokerConsumer
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:746 +0x216

goroutine 643 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x76ffd0?, {0x145b8b8, 0xc0003f4460})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 658 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0xa30fd0?, {0x145b8b8, 0xc0009d2320})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 661 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x197d0?, {0x145b8b8, 0xc00019e280})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 695 [chan receive]:
github.com/Shopify/sarama.(*partitionConsumer).responseFeeder(0xc00019e500)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:463 +0x92
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:162 +0x345

goroutine 756 [select]:
github.com/Shopify/sarama.(*brokerConsumer).subscriptionManager(0xc00042c7d0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:772 +0x252
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).newBrokerConsumer
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:745 +0x19a

goroutine 651 [runnable]:
github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic.func3(0x76f7d0?, {0x145b8b8, 0xc0005f4b40})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:494 +0xd0
created by github.com/elastic/beats/v7/libbeat/outputs/kafka.testReadFromKafkaTopic
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/src/github.com/elastic/beats/libbeat/outputs/kafka/kafka_integration_test.go:492 +0x1a7

goroutine 754 [chan receive, 9 minutes]:
github.com/Shopify/sarama.(*partitionConsumer).dispatcher(0xc00036e320)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:343 +0x3d
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*consumer).ConsumePartition
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/consumer.go:161 +0x2ca

goroutine 689 [runnable]:
internal/poll.runtime_pollWait(0x7f66ee8884f8, 0x72)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/runtime/netpoll.go:302 +0x89
internal/poll.(*pollDesc).wait(0xc0002bc080?, 0xc00095f000?, 0x0)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/internal/poll/fd_poll_runtime.go:83 +0x32
internal/poll.(*pollDesc).waitRead(...)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/internal/poll/fd_poll_runtime.go:88
internal/poll.(*FD).Read(0xc0002bc080, {0xc00095f000, 0x1000, 0x1000})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/internal/poll/fd_unix.go:167 +0x25a
net.(*netFD).Read(0xc0002bc080, {0xc00095f000?, 0x6fc23a979?, 0x72?})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/net/fd_posix.go:55 +0x29
net.(*conn).Read(0xc000318050, {0xc00095f000?, 0x92a0e56b6d?, 0x1c98da0?})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/net/net.go:183 +0x45
bufio.(*Reader).Read(0xc000a6ba40, {0xc0000ce928, 0x8, 0x1c98da0?})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/bufio/bufio.go:236 +0x1b4
github.com/Shopify/sarama.(*bufConn).Read(0x10000c000a6bce0?, {0xc0000ce928?, 0xc00008fde0?, 0x7f8f56?})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:107 +0x25
io.ReadAtLeast({0x7f66c5b49328, 0xc00025a468}, {0xc0000ce928, 0x8, 0x8}, 0x8)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/io/io.go:331 +0x9a
io.ReadFull(...)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/.gvm/versions/go1.18.4.linux.amd64/src/io/io.go:350
github.com/Shopify/sarama.(*Broker).readFull(0xc000718380, {0xc0000ce928, 0x8, 0x8})
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:748 +0xc5
github.com/Shopify/sarama.(*Broker).responseReceiver(0xc000718380)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:904 +0x145
github.com/Shopify/sarama.withRecover(0x0?)
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/utils.go:43 +0x3e
created by github.com/Shopify/sarama.(*Broker).Open.func1
	/var/lib/jenkins/workspace/PR-32493-1-87941495-4128-44fb-b227-0e2c1d3ac08c/pkg/mod/github.com/elastic/sarama@v1.19.1-0.20220310193331-ebc2b0d8eef3/broker.go:212 +0xb2b

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(0):_publish_single_event_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(0):_publish_single_event_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.301Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.302Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:21.762Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(1):_publish_single_event_with_topic_from_type – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(1):_publish_single_event_with_topic_from_type
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.164Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.165Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:23.468Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(2):_publish_single_event_with_formating_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(2):_publish_single_event_with_formating_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.791Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:24.817Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.195Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.197Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.198Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(3):_batch_publish_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(3):_batch_publish_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.200Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.200Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:26.326Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.749Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.752Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:27.763Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(5):_batch_publish_with_random_partitioner – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(5):_batch_publish_with_random_partitioner
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.476Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.477Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:29.628Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.018Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.018Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:31.019Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(8):_batch_publish_with_hash_partitioner_with_key – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(8):_batch_publish_with_hash_partitioner_with_key
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.587Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.587Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:34.837Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(9):_batch_publish_with_fields_hash_partitioner – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(9):_batch_publish_with_fields_hash_partitioner
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.422Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:36.423Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:37.026Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.730Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.730Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.778Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(10):_publish_single_event_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
    Expand to view the error details

     Failed

    Expand to view the stacktrace

     === RUN   TestKafkaPublish/run_test(10):_publish_single_event_to_test_topic
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.780Z","log.logger":"kafka","log.origin":{"file.name":"kafka/kafka.go","file.line":48},"message":"initialize kafka output","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:38.781Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":120},"message":"connect: [localhost:9094]","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:39.106Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":392},"message":"finished kafka batch","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.917Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":141},"message":"closed kafka client","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.917Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":262},"message":"Stop kafka ack worker","ecs.version":"1.6.0"}
{"log.level":"debug","@timestamp":"2022-07-25T22:33:40.944Z","log.logger":"kafka","log.origin":{"file.name":"kafka/client.go","file.line":352},"message":"Stop kafka error handler","ecs.version":"1.6.0"}

Steps errors 10

Expand to view the steps failures

Sleep
  • Took 0 min 7 sec . View more details here
  • Description: 5
filebeat-goIntegTest - mage goIntegTest
  • Took 6 min 48 sec . View more details here
  • Description: mage goIntegTest
filebeat-goIntegTest - mage goIntegTest
  • Took 3 min 42 sec . View more details here
  • Description: mage goIntegTest
filebeat-goIntegTest - mage goIntegTest
  • Took 3 min 34 sec . View more details here
  • Description: mage goIntegTest
libbeat-goIntegTest - mage goIntegTest
  • Took 15 min 42 sec . View more details here
  • Description: mage goIntegTest
libbeat-goIntegTest - mage goIntegTest
  • Took 12 min 50 sec . View more details here
  • Description: mage goIntegTest
libbeat-goIntegTest - mage goIntegTest
  • Took 12 min 43 sec . View more details here
  • Description: mage goIntegTest
metricbeat-goIntegTest - mage goIntegTest
  • Took 30 min 24 sec . View more details here
  • Description: mage goIntegTest
x-pack/filebeat-goIntegTest - mage goIntegTest
  • Took 13 min 31 sec . View more details here
  • Description: mage goIntegTest
Error signal
  • Took 0 min 0 sec . View more details here
  • Description: Error 'hudson.AbortException: script returned exit code 1'

🐛 Flaky test report

❕ There are test failures but not known flaky tests.

Expand to view the summary

Genuine test errors 14

💔 There are test failures but not known flaky tests, most likely a genuine test failure.

  • Name: Build&Test / filebeat-goIntegTest / TestSASLAuthentication – github.com/elastic/beats/v7/filebeat/input/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(0):_publish_single_event_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(1):_publish_single_event_with_topic_from_type – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(2):_publish_single_event_with_formating_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(3):_batch_publish_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(5):_batch_publish_with_random_partitioner – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(8):_batch_publish_with_hash_partitioner_with_key – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(9):_batch_publish_with_fields_hash_partitioner – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(10):_publish_single_event_to_test_topic – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(11):_publish_single_event_to_test_topic_over_SASL/SCRAM – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(4):_batch_publish_to_test_topic_from_type – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(6):_batch_publish_with_round_robin_partitioner – github.com/elastic/beats/v7/libbeat/outputs/kafka
  • Name: Build&Test / libbeat-goIntegTest / TestKafkaPublish/run_test(7):_batch_publish_with_hash_partitioner_without_key_(fallback_to_random) – github.com/elastic/beats/v7/libbeat/outputs/kafka

🤖 GitHub comments

To re-run your PR in the CI, just comment with:

  • /test : Re-trigger the build.

  • /package : Generate the packages and run the E2E tests.

  • /beats-tester : Run the installation tests with beats-tester.

  • run elasticsearch-ci/docs : Re-trigger the docs validation. (use unformatted text in the comment!)

@v1v
Copy link
Member

v1v commented Jul 26, 2022

/package

@cmacknz cmacknz self-requested a review July 26, 2022 15:36
@cmacknz cmacknz added the Team:Elastic-Agent-Data-Plane Label for the Agent Data Plane team label Jul 26, 2022
@elasticmachine
Copy link
Contributor

elasticmachine commented Jul 26, 2022

Pinging @elastic/elastic-agent-data-plane (Team:Elastic-Agent-Data-Plane)

@botelastic botelastic bot removed the needs_team Indicates that the issue/PR needs a Team:* label label Jul 26, 2022
@cmacknz cmacknz mentioned this pull request Jul 26, 2022
Closed
5 tasks
@cmacknz
Copy link
Member

cmacknz commented Jul 26, 2022

Tests are blocked by #30954

@cmacknz cmacknz assigned cmacknz and unassigned ghost Aug 4, 2022
@cmacknz cmacknz removed their request for review August 4, 2022 19:39
@cmacknz cmacknz mentioned this pull request Aug 4, 2022
Merged
3 tasks
cmacknz added 2 commits August 10, 2022 13:43
@cmacknz
Upgrade to elastic-agent-libs v0.2.11
ce5de35 
Ensures the linter is automatically upgraded when it's version changes.
@cmacknz
Fixes to support Go 1.18 (#32611)
d649c41 
* Update Kafka base image to Debian buster.

Done to allow updating to OpenJDK 11 to ensure compatibility with the
output from keytool on my local machine that used a much more recent
version of OpenJDK.

* Regenerate Kafka certs to use SHA-256.

The certificates were previously signed with SHA-1 which is deprecated
in Go 1.18 due to being insecure.

* Rename test cases so they can be run  individually
* Upgrade elastic-agent-libs
* Upgrade golangci-lint in actions.
* Update notice file.
* Add release note for Go 1.18 upgrade.
@mergify mergify bot closed this Aug 10, 2022
@mergify
Copy link
Contributor

mergify bot commented Aug 10, 2022

This pull request has been automatically closed by Mergify.
There are some other up-to-date pull requests.

@mergify mergify bot deleted the update-go-version-20220725210948-main branch August 10, 2022 17:48
@cmacknz cmacknz restored the update-go-version-20220725210948-main branch August 10, 2022 17:49
@cmacknz cmacknz reopened this Aug 10, 2022
@cmacknz
Copy link
Member

cmacknz commented Aug 10, 2022

/test

@mergify mergify bot closed this Aug 10, 2022
@mergify
Copy link
Contributor

mergify bot commented Aug 10, 2022

This pull request has been automatically closed by Mergify.
There are some other up-to-date pull requests.

@mergify mergify bot deleted the update-go-version-20220725210948-main branch August 10, 2022 17:49
@elasticmachine
Copy link
Contributor

elasticmachine commented Aug 10, 2022

💔 Build Failed

the below badges are clickable and redirect to their specific view in the CI or DOCS
Pipeline View Test View Changes Artifacts preview preview

Expand to view the summary

Build stats

  • Start Time: 2022-08-10T17:45:14.447+0000

  • Duration: 5 min 40 sec

Steps errors 1

Expand to view the steps failures

Shell Script
  • Took 0 min 0 sec . View more details here
  • Description: git diff --name-only origin/main...ce5de35ded4b4c0d425a50ffc1da3b853aa9c6c0 > git-diff.txt

❕ Flaky test report

No test was executed to be analysed.

🤖 GitHub comments

To re-run your PR in the CI, just comment with:

  • /test : Re-trigger the build.

  • /package : Generate the packages and run the E2E tests.

  • /beats-tester : Run the installation tests with beats-tester.

  • run elasticsearch-ci/docs : Re-trigger the docs validation. (use unformatted text in the comment!)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@fearful-symmetry fearful-symmetry Awaiting requested review from fearful-symmetry fearful-symmetry is a code owner automatically assigned from elastic/elastic-agent-data-plane

@faec faec Awaiting requested review from faec faec is a code owner automatically assigned from elastic/elastic-agent-data-plane

Assignees

@cmacknz cmacknz

Labels

automation backport-skip Skip notification from the automated backport with mergify dependency Team:Elastic-Agent-Data-Plane Label for the Agent Data Plane team

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

3 participants

@elasticmachine @v1v @cmacknz