confluentinc / librdkafka

The Apache Kafka C/C++ library
Other
7.37k stars 3.11k forks source link

Produce upgrade to flexver plus tests #4595

Closed anchitj closed 2 weeks ago

emasab commented 3 weeks ago

Please rebase on feature/fetch-951-prework-v13+ and use rd_kafka_buf_write_tags_empty In rd_kafka_mock_connection_read_request use rd_kafka_buf_skip_str_no_flexver here: https://github.com/confluentinc/librdkafka/blob/465f81cee46255f29ea71f17ff90092100b1326c/src/rdkafka_mock.c#L1108

emasab commented 3 weeks ago

Upgrade Produce mock handler to 9 in this PR

anchitj commented 3 weeks ago

Rebased with https://github.com/confluentinc/librdkafka/pull/4584/files and addressing comments