2.3.1

2.3.1 (Apr 9, 2026)

Fixes

• Fix TaggedFields value encoding; add test coverage (#2725)
• Fix zstd multi-frame decompression failure (#2717)
• Fix KeyError in KafkaConsumer.committed() (#2710)
• Fix VarInt/VarLong encoding; move tests to test/protocol/ (#2706)
• Fix Fetcher._fetch_offsets_by_times retry handling (#2833)
• Fixes to support integration testing with external KAFKA_URI (#2838)
• Minor py2 fixes: consumer integration test; dont pip install python-snappy