WriteMessages should return offset about kafka-go HOT 5 CLOSED

I prefer func (*Conn) Produce(req *ProduceRequest) (res *ProduceResponse, err error), also fwiw this is similar to existing Producer APIs for example https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send-org.apache.kafka.clients.producer.ProducerRecord-

from kafka-go.

@silence44 I think we could get this in pretty quick, let me see if we can get a PR up for next week.

from kafka-go.

Is this feature in progress right now?
I want to switch from sarama to segmetio but this missing feature stops me. Is there another way to get write offset in current library version?

from kafka-go.

I could take on this task.
If I understand correctly, all the necessary data is written in the method produceResponsePartitionV2.readFrom. Is it so?
Do you want to make a new method

func (*Conn) Produce(req *ProduceRequest) (res *ProduceResponse, err error)

analogue of the

func (c *Conn) WriteCompressedMessages(codec CompressionCodec, msgs ...Message) (int, error)

?

In the current code, it is faster to make this variant

func (c *Conn) WriteCompressedMessagesAt(codec CompressionCodec, msgs ...Message) (nbytes int, partition int32, offset int64, timestamp int64, err error)

from kafka-go.

@scarbo87 after some discussions with @achille-roussel we decided to introduce a new client rather modify the existing ones. I'm out until Jan 4th, so current ETA on this for me is week of Jan 7th. If you need it sooner and want to take a pass at it, PRs are always welcome 👍

from kafka-go.