1.0.0-alpha.7

What's Changed

• [cherry-pick] Allow old-style C calls for librdkafka by @blindspotbounty in #174

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

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

1.0.0-alpha.5

What's Changed

• Expose librdkafka statistics as swift metrics by @blindspotbounty in #92
• Add benchmark infratructure without actual tests by @blindspotbounty in #146
• Update to latest librdkafka & add a define for RAND_priv_bytes (#138) by @axelandersson in #148

New Contributors

• @axelandersson made their first contribution in #148

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

1.0.0-alpha.4

What's Changed

• Consumer: assign / subscribe on run() by @felixschlegel in #133
• KafkaConsumer.commitAsync by @felixschlegel in #126
• Make triggerGracefulShutdown() public by @blindspotbounty in #130
• Generate CONTRIBUTORS.txt by @felixschlegel in #134
• Add CI pipeline for Swift 5.10 in #137
• Ship with BoringSSL by @felixschlegel in #135
• Fix error test when ignoring RD_KAFKA_RESP_ERR_NO_ERROR in storeMessageOffset in #141
• KafkaConsumer: back pressure + improved read speed by @felixschlegel in #139

New Contributors

• @blindspotbounty made their first contribution in #130

Full Changelog: 1.0.0-alpha.3...1.0.0-alpha.4

1.0.0-alpha.3

What's Changed

• KafkaProducer.makeProducerWithEvents() avoid fatalError in #117
• Remove superfluous guard statementsin #118
• KafkaConsumer: store offsets when .finishing in #121
• KafkaConsumer: change locality of message error in #122
• Kafka Message Header API by in #120
• storeMessageOffset: ignore state error by in #129

Full Changelog: 1.0.0-alpha.2...1.0.0-alpha.3

1.0.0-alpha.2

What's changed

• Fix typo tlsConfiguaration -> tlsConfiguration (#116)

1.0.0-alpha.1

This is the first alpha release of swift-kafka-client.

What's new

This initial release provides a KafkaConsumer and a KafkaProducer which can be used to interact with a Kafka cluster.
To learn more checkout the Usage section in the README.

Key Features

• Consumer Groups: Consume messages with consumer groups
• Message Reliability: Producer allows for checking the status of a message after being sent
• Swift Concurrency: This package leverages Swift's latest concurrency features
• Security: Support for SASL and TLS
• Logging: Direct integration with swift-log

Get Involved

We are actively seeking feedback on the API, usability and performance. Please use GitHub or Swift Forums to share your thoughts on the package!