zero

> Hello @gwy1995 Thanks for your contribution. Could you please sign our CLA? I have signed it for three times , but it still shows as unsigned in this issue....

> Did you sign it with the same email than your github account? yes, I have sign it today and yesterday for more than three times.

> Hi @gwy1995, we can try figuring out where the CLA checker is having trouble, but another issue I notice is that you removed Elastic's [sarama fork](https://github.com/elastic/sarama) and replaced it...

> looks good. Any chance you could add a test case to > > https://github.com/elastic/beats/blob/42dc965a50853c282ef4407683711e1cf5b3bbb8/libbeat/outputs/kafka/kafka_integration_test.go#L57 > > ? I add a test case. But I don't know why it didn't...

> @gwy1995 Could you please retry to sign the CLA? This is a mandatory step to be able to merge your PR. hi, I finally successfully signed the CLA

> We have a failing test @gwy1995 > > ``` > === Failed > -- >   | === FAIL: libbeat/outputs/kafka TestKafkaPublish/run_test(13):_publish_message_with_zstd_compression_to_test_topic (0.00s) >   | kafka_integration_test.go:278: unknown/unsupported kafka version '2.2.2' accessing...

> > We have a failing test @gwy1995 > > ``` > > === Failed > > -- > >   | === FAIL: libbeat/outputs/kafka TestKafkaPublish/run_test(13):_publish_message_with_zstd_compression_to_test_topic (0.00s) > >   | kafka_integration_test.go:278:...