Support for offsetdelete

[a-dot]

Closes #1009

The tests need kafka 2.4 to successfully run.

[rhansen2]

Hi @a-dot,

Thanks for the contribution! You can use a construct like

kafka-go/createpartitions_test.go

Line 11 in d8dd9b0

if !ktesting.KafkaIsAtLeast("1.0.1") {

to gate your tests around the proper kafka versions.

[a-dot]

Hi @a-dot,

Thanks for the contribution! You can use a construct like

kafka-go/createpartitions_test.go

Line 11 in d8dd9b0

if !ktesting.KafkaIsAtLeast("1.0.1") {

to gate your tests around the proper kafka versions.

Awesome! Thanks for the tip. I fixed that.

[a-dot]

Any hints as to why the tests fail on kafka-271 would be appreciated. Unless I'm mistaken, it doesn't look like it's my test that is failing?

[rhansen2]

The test failure looked like some unrelated flakiness. I re-ran the failed job and it looks good.

[rhansen2]

LGTM!