Ecosyste.ms: Issues
An open API service for providing issue and pull request metadata for open source projects.
GitHub / swift-server/swift-kafka-client issues and pull requests
#165 - [placeholder] Use task preferences for blocking polls
Issue -
State: open - Opened by blindspotbounty 7 months ago
#164 - [producer message] Allow optional key for initializer
Pull Request -
State: closed - Opened by hyerra 7 months ago
- 1 comment
#163 - Use returned error
Pull Request -
State: closed - Opened by blindspotbounty 8 months ago
#162 - Update librdkafka for BoringSSL
Pull Request -
State: closed - Opened by Samsv77 8 months ago
- 1 comment
#161 - Allow groupID to be specified when assigning partition
Pull Request -
State: closed - Opened by omarkj 11 months ago
- 8 comments
#160 - Commit messages by topic, partition, offset
Pull Request -
State: open - Opened by omarkj 11 months ago
- 1 comment
#159 - Wrap Sendability warning for OpaquePointer
Issue -
State: open - Opened by blindspotbounty 11 months ago
#158 - Wrap rd_kafka_consumer_poll into iterator (use librdkafka embedded backpressure)
Pull Request -
State: closed - Opened by blindspotbounty 11 months ago
- 3 comments
#157 - Defer source.finish()
Pull Request -
State: closed - Opened by blindspotbounty 12 months ago
#156 - Allow to get metadata from kafka
Issue -
State: open - Opened by blindspotbounty 12 months ago
#155 - Remove curl dependency and disable OAuth Bearer SASL mechanism
Pull Request -
State: open - Opened by FranzBusch 12 months ago
#154 - Lower requirements for consumer state machine
Pull Request -
State: closed - Opened by blindspotbounty 12 months ago
#153 - exit from consumer batch loop when no more messages left
Pull Request -
State: closed - Opened by blindspotbounty 12 months ago
#152 - In rdkafka_sasl_oauthbearer_oidc.c - 'curl/curl.h' file not found
Issue -
State: open - Opened by saujidaprostem 12 months ago
- 4 comments
#151 - A lot of idling in KafkaConsumer.batchConsumerPoll
Issue -
State: closed - Opened by blindspotbounty 12 months ago
- 1 comment
#150 - Crash when sending message with headers
Issue -
State: open - Opened by blindspotbounty 12 months ago
- 1 comment
#149 - Add two consumer benchmark
Pull Request -
State: closed - Opened by blindspotbounty 12 months ago
- 5 comments
#148 - Update to latest librdkafka & add a define for RAND_priv_bytes (#138)
Pull Request -
State: closed - Opened by axelandersson 12 months ago
- 4 comments
#147 - `KafkaConsumer` may crash if deinit called before run
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 1 comment
#146 - Add benchmark infratructure without actual tests
Pull Request -
State: closed - Opened by blindspotbounty about 1 year ago
- 4 comments
#145 - Poll batches according to backpressure
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 1 comment
#144 - KafkaAcknowledgedMessage lacks headers
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 1 comment
Labels: good first issue
#143 - feat(patch): [sc-4740] kafka rebase+abort
Pull Request -
State: closed - Opened by blindspotbounty about 1 year ago
#142 - Revert "Ship with BoringSSL (#135)"
Pull Request -
State: closed - Opened by FranzBusch about 1 year ago
#141 - Fix error test when ignoring RD_KAFKA_RESP_ERR_NO_ERROR in storeMessageOffset
Pull Request -
State: closed - Opened by gmilos about 1 year ago
- 2 comments
#140 - Consumer performance benchmark
Pull Request -
State: open - Opened by blindspotbounty about 1 year ago
- 5 comments
#139 - `KafkaConsumer`: back pressure + improved read speed
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
- 2 comments
#138 - Undeclared function 'RAND_priv_bytes' after switch to BoringSSL
Issue -
State: open - Opened by axelandersson about 1 year ago
- 6 comments
#137 - Add CI pipeline for Swift 5.10
Pull Request -
State: closed - Opened by rnro about 1 year ago
- 4 comments
#136 - Duplicated messages when default rebalance happening with 2+ consumers and offset auto commit disabled
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 2 comments
#135 - Ship with BoringSSL
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
- 2 comments
#134 - Generate CONTRIBUTORS.txt
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
#133 - Consumer: `assign` / `subscribe` on `run()`
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
#132 - swift-kafka-client consumer is very slow (was: Provide bulk messages from `KafkaConsumer`)
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 8 comments
#131 - Enable back pressure for KafkaConsumer
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 8 comments
#130 - Make triggerGracefulShutdown() public
Pull Request -
State: closed - Opened by blindspotbounty about 1 year ago
- 1 comment
#129 - `storeMessageOffset`: ignore state error
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
#128 - Commit method respond slow (was: Make poll interval adaptive)
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 3 comments
#127 - Make KafkaError more catch friendly and efficient
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 6 comments
#126 - `KafkaConsumer.commitAsync`
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
- 3 comments
#125 - Make `triggerGracefulShutdown()` public (was: De-couple Kafka from ServiceLifecycle to separate target)
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 6 comments
#124 - Listen and propagate RD_KAFKA_RESP_ERR__PARTITION_EOF
Issue -
State: open - Opened by blindspotbounty about 1 year ago
- 7 comments
#123 - rdkafka: SSL requirement
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 5 comments
#122 - `KafkaConsumer`: change locality of message error
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
- 1 comment
#121 - `KafkaConsumer`: store offsets when `.finishing`
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
- 1 comment
#120 - Kafka Message Header API
Pull Request -
State: closed - Opened by felixschlegel about 1 year ago
#119 - Store offset on .finishing may lead to fatalError
Issue -
State: closed - Opened by blindspotbounty about 1 year ago
- 4 comments
#118 - Remove superfluous `guard` statements
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#117 - `KafkaProducer.makeProducerWithEvents()` avoid `fatalError`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#116 - Fix typo `tlsConfiguaration` -> `tlsConfiguration`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#115 - Enable Sendability checks on CI
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 3 comments
#114 - Fix sendability warnings
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#113 - Fix: Kafka consumer leaves group after 5 mins
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#112 - Fix hard-coded value bug in `KafkaTests`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#111 - `TLSConfiguration`: separate client and broker TLS configuration
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 2 comments
#110 - Kafka consumer leaves group after 5 mins
Issue -
State: closed - Opened by blindspotbounty over 1 year ago
- 2 comments
#109 - Readme with Public API v1
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#108 - Rename to `swift-kafka-client`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#107 - avoid setting default values to topic configuration
Pull Request -
State: closed - Opened by blindspotbounty over 1 year ago
#106 - TopicConfiguration default values should not be set to librdkafka config
Issue -
State: open - Opened by blindspotbounty over 1 year ago
- 1 comment
#105 - `KafkaFoundationCompat`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#104 - Public API v1
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#103 - Fix conversion from String to Bytes
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#102 - Fix: `KafkaConsumer` crashes with autoCommit=true
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#101 - Remove `KafkaError.ErrorCode.acknowledgement`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#100 - Committing offset on stopping leads to fatalError
Issue -
State: closed - Opened by blindspotbounty over 1 year ago
- 1 comment
#99 - Consumer autocommit lead to crash
Issue -
State: closed - Opened by blindspotbounty over 1 year ago
- 3 comments
#98 - add approx. transactional api
Pull Request -
State: open - Opened by blindspotbounty over 1 year ago
#97 - `KafkaConsumer`: expose event sequence
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#96 - `KafkaProducer`: events- instead of acks sequence
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#95 - `KafkaProducerMessage`: generic key & value
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#94 - `KafkaProducer`: refactor flushing
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 2 comments
#93 - Does `KafkaProducerMessage` suppose to copy bytes to ByteBuffer?
Issue -
State: closed - Opened by blindspotbounty over 1 year ago
- 2 comments
#92 - Feature: expose librdkafka statistics as swift metrics
Pull Request -
State: closed - Opened by blindspotbounty over 1 year ago
- 12 comments
#91 - `KafkaConfiguration`: Rename `SSL*` to `TLS*`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#90 - New Config: de-duplicate setters/getters properties
Issue -
State: closed - Opened by blindspotbounty over 1 year ago
- 8 comments
#89 - Move `KafkaClient` to `RD*` namespace
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#88 - Type-safe Security Configuration
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#87 - Refactor `*Configuration` types
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#86 - `KafkaConsumer`: replace callbacks with `eventPoll`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#85 - `KafkaConsumer`: drop messages on sequence termination
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#84 - `KafkaProducer`: Drop acks on sequence termination
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 2 comments
#83 - Remove `@unchecked Sendable`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#82 - `KafkaProducer`: replace callbacks with `eventPoll`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#81 - Adopt `swift-service-lifecycle`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#80 - Fix Soundness + update contributors
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#79 - Redefine statistics callback
Issue -
State: closed - Opened by mr-swifter over 1 year ago
- 1 comment
#78 - Transactional API
Issue -
State: open - Opened by mr-swifter over 1 year ago
- 1 comment
#76 - `README`: improve `KafkaProducer` examples
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#75 - Functionality wishlist
Issue -
State: open - Opened by mr-swifter over 1 year ago
- 3 comments
#73 - Fix: `KafkaClient.closeConsumer` should not block
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#72 - `KafkaConsumer`: move `ConsumptionStrategy` to `init`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#68 - Fix: `KafkaConsumer.commitSync` should not block
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#67 - Refactor `KafkaProducer`
Pull Request -
State: closed - Opened by felixschlegel over 1 year ago
#61 - Add an option to redirect librdkafka logging to Logger
Pull Request -
State: closed - Opened by mr-swifter over 1 year ago
- 6 comments
#60 - Be able to redirect librdkafka logging to Logger
Issue -
State: closed - Opened by mr-swifter over 1 year ago
#57 - Do we still need `KafkaProducer.shutdownGracefully()`?
Issue -
State: closed - Opened by felixschlegel over 1 year ago
- 1 comment
#46 - New Config API: Re-evaluate public API & configuration options
Issue -
State: open - Opened by felixschlegel almost 2 years ago
- 1 comment
#37 - Replace `weak` reference to `KafkaConsumer` in `ConsumerMessagesAsyncSequenceDelegate`
Issue -
State: closed - Opened by felixschlegel about 2 years ago
#31 - Make a Kafka Cluster's meta data accessible
Issue -
State: open - Opened by felixschlegel about 2 years ago
- 1 comment