v6.1.0

6.1.0 (2026-10-14)

Features

• kafka: add consumer_options.pipelining_strategy (6455267)
• kafka: add pipelining_strategy: Serial for partition ordering (4a656b0)
• kafka: keep one record per partition in flight with pipelining_strategy: Serial (f13a57d)
• kafka: open the serial gate on a settling worker reply (f6accaa)

Bug Fixes

• kafka: start one listener per pipeline across pause and resume (07936f9)