1.0.0-alpha.6

What's Changed

• exit from consumer batch loop when no more messages left by @blindspotbounty in #153
• Lower requirements for consumer state machine by @blindspotbounty in #154
• Defer source.finish() by @blindspotbounty in #157
• Add two consumer benchmark by @blindspotbounty in #149
• Update librdkafka for BoringSSL by @Samsv77 in #162
• Use returned error by @blindspotbounty in #163
• [producer message] Allow optional key for initializer by @hyerra in #164
• Allow groupID to be specified when assigning partition by @omarkj in #161
• Wrap rd_kafka_consumer_poll into iterator (use librdkafka embedded backpressure) by @blindspotbounty in #158

New Contributors

• @Samsv77 made their first contribution in #162
• @hyerra made their first contribution in #164
• @omarkj made their first contribution in #161

Full Changelog: 1.0.0-alpha.5...1.0.0-alpha.6