swift-kafka-client

swift-kafka-client copied to clipboard

# Motivation The curl dependency is just necessary for the OAuth Bearer SASL mechanism. Let's remove that configuration option for now. # Modification Removes the curl dependency.

FranzBusch

Currently there is a workaround with sleeps and pollIntervals: https://github.com/swift-server/swift-kafka-client/pull/158/files#diff-8ba8c17c39d40fc29ec22c104d01bacc928df36e717000547f2a97d4203ef6a1R93 We have to fix that when [implemented](https://github.com/apple/swift-evolution/blob/main/proposals/0417-task-executor-preference.md)

blindspotbounty

Crash when sending message with headers

1

For some situations, headers could be freed by librdkafka thus leading to crash: ``` Thread 5 Queue : com.apple.root.user-initiated-qos.cooperative (concurrent) #0 0x0000000189d4d11c in __pthread_kill () #1 0x0000000189d84cc0 in pthread_kill ()...

blindspotbounty

Commit messages by topic, partition, offset

1

Motivation: In some cases, for instances when messages are handed out to other processes, it is not reasonable to hold on to the whole Kafka message to be able to...

omarkj

Functionality wishlist

3

Hello! As I mention before I really eager to jump off from my home made implementation of Swift Kafka API and use this version and ready to contribute to make...

mr-swifter

Duplicated messages when default rebalance happening with 2+ consumers and offset auto commit disabled

2

Currently, swift-kafka-client does not support rebalance callback/event. However, that is pretty important thing to avoid duplicated messages from the broker. The typical scenario for a lot of applications is to...

blindspotbounty

According to proposal https://github.com/apple/swift-evolution/blob/main/proposals/0331-remove-sendable-from-unsafepointer.md OpaquePointer is no longer Sendable (also [comment](https://github.com/apple/swift/issues/70396#issuecomment-1851497237)) Let's fix that by wrapping it or by setting `@unchecked Sendable`

blindspotbounty

In rdkafka_sasl_oauthbearer_oidc.c - 'curl/curl.h' file not found

4

Header Search Paths: Open your Xcode project, select the target, go to "Build Settings," and add the following path to "Header Search Paths": /usr/local/opt/curl/include Library Search Paths: Add the library...

saujidaprostem

Consumer performance benchmark

5

This PR addresses the need of performance measurements for #132 ## Motivation Reading messages with swift-kafka-client KafkaConsumer is up to 50x slower than librdkafka allows. The following results with 500000...

blindspotbounty

Sometimes it is required to know topics registered on broker and number of partitions, replicas per topic. librdkafka has method `rd_kafka_metadata(...)` to provide such information. Would be nice to be...

blindspotbounty