Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / bloomberg/corokafka issues and pull requests

#64 - Fix C++20 Issue

Pull Request - State: closed - Opened by demin80 over 2 years ago

#63 - Skip empty headers when serializing messages.

Pull Request - State: closed - Opened by arosenzweig3 almost 3 years ago

#62 - Demonstrate race condition in OffsetManager::saveOffset

Pull Request - State: closed - Opened by arosenzweig3 almost 3 years ago - 5 comments

#61 - Demonstrate race condition

Pull Request - State: closed - Opened by arosenzweig3 almost 3 years ago - 2 comments

#60 - Fix compiler issues in GCC 9

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#59 - Added cpp headers for compile-time mock checks

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#58 - OffsetManager improvements

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#57 - Split enableCommitTracing() into two separate overloads

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#56 - Specify the log severity level when outputting commit messages in the…

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#55 - Error when compile with gcc 9

Issue - State: closed - Opened by linuxpham almost 4 years ago - 4 comments

#54 - Updated to use the latest quantum GenericFuture changes. The future t…

Pull Request - State: closed - Opened by accelerated almost 4 years ago

#53 - Offset manager mock

Pull Request - State: closed - Opened by accelerated about 4 years ago

#52 - Reset offset to low watermark in OffsetManager

Pull Request - State: closed - Opened by accelerated about 4 years ago

#49 - Provide validation checks for idempotence and message retries

Pull Request - State: closed - Opened by accelerated over 4 years ago

#48 - Force enable.auto.offset.store=false

Pull Request - State: closed - Opened by accelerated over 4 years ago

#47 - Fixed extraction of values from topic_options

Pull Request - State: closed - Opened by accelerated over 4 years ago

#46 - Added broker timeout for metadata operations

Pull Request - State: closed - Opened by accelerated over 4 years ago

#45 - Added latency support in the DeliveryReport class

Pull Request - State: closed - Opened by accelerated over 4 years ago

#44 - Removed newlines in JSON schema as they are rejected by RapidJson

Pull Request - State: closed - Opened by accelerated over 4 years ago

#42 - Added logging capability to the OffsetManager

Pull Request - State: closed - Opened by accelerated over 4 years ago

#41 - - Changed pause/resume to use topic instead of current assignment

Pull Request - State: closed - Opened by accelerated over 4 years ago

#40 - Always register rebalance callbacks

Pull Request - State: closed - Opened by accelerated over 4 years ago

#39 - Update watermark on each message

Pull Request - State: closed - Opened by accelerated over 4 years ago

#38 - Added validity check for HeaderPack

Pull Request - State: closed - Opened by accelerated over 4 years ago

#37 - Fixed invalid header iterator dereference

Pull Request - State: closed - Opened by accelerated over 4 years ago

#37 - Fixed invalid header iterator dereference

Pull Request - State: closed - Opened by accelerated over 4 years ago

#35 - Skip commit if message is errored

Pull Request - State: closed - Opened by accelerated over 4 years ago

#34 - Removed .at() access to allow for clearer exception messages

Pull Request - State: closed - Opened by accelerated over 4 years ago

#33 - Finish poll cycle during shutdown

Pull Request - State: closed - Opened by accelerated over 4 years ago - 1 comment

#32 - Added gmocks

Pull Request - State: closed - Opened by accelerated over 4 years ago

#31 - Named corokafka thread (unix only)

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#30 - Adjust current offset on start for OffsetManager.

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#29 - Fixed intermittend failing test

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#28 - API code review

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#27 - Added optional separate timeout for querying brokers

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#26 - Moved mutex lock to only protect ranges for better performance.

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#25 - Added separate consumer timeout on startup. Lazy offset watermark que…

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#24 - Updated drain default parameter to reflect quantum::dispatcher::drain…

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#23 - Fixed message offset + 1 discrepancy. Added additional test for Offse…

Pull Request - State: closed - Opened by accelerated almost 5 years ago

#22 - Various performance improvements and refactoring

Pull Request - State: closed - Opened by accelerated almost 5 years ago - 1 comment

#21 - Gtests

Pull Request - State: closed - Opened by accelerated about 5 years ago

#20 - Added consumer tests

Pull Request - State: closed - Opened by accelerated about 5 years ago

#19 - Added consumer tests

Pull Request - State: closed - Opened by accelerated about 5 years ago

#18 - Added producer tests and various small changes

Pull Request - State: closed - Opened by accelerated about 5 years ago

#17 - Added unit tests for configuration options

Pull Request - State: closed - Opened by accelerated about 5 years ago

#16 - Added unit tests for configuration options

Pull Request - State: closed - Opened by accelerated about 5 years ago

#15 - Exceptions

Pull Request - State: closed - Opened by accelerated about 5 years ago

#14 - Initial .travis file

Pull Request - State: closed - Opened by accelerated about 5 years ago

#13 - Converted stream operators to output in JSON format

Pull Request - State: closed - Opened by accelerated about 5 years ago

#12 - Added getLatency() API for produced messages

Pull Request - State: closed - Opened by accelerated about 5 years ago

#11 - Set paused flag to true if pausing consumer on start

Pull Request - State: closed - Opened by accelerated about 5 years ago

#10 - Make pause/resume atomic

Pull Request - State: closed - Opened by accelerated about 5 years ago

#9 - Move partition assignment configuration to the topic section.

Pull Request - State: closed - Opened by accelerated about 5 years ago

#8 - Pass topic partition by reference in pre-processor function

Pull Request - State: closed - Opened by accelerated about 5 years ago

#7 - Fix offset commit value when offset range is > 1

Pull Request - State: closed - Opened by accelerated about 5 years ago

#6 - Do not start coroutine for deserializing if message set is empty

Pull Request - State: closed - Opened by accelerated over 5 years ago

#5 - Fixed batch count when messages are less than the number of coroutines

Pull Request - State: closed - Opened by accelerated over 5 years ago

#3 - Add Travis-CI support

Issue - State: closed - Opened by kpfleming over 5 years ago - 1 comment

#2 - Fixed spelling mistake

Pull Request - State: closed - Opened by accelerated over 5 years ago

#1 - Added explanation for serializer concepts

Pull Request - State: closed - Opened by accelerated over 5 years ago