-
Notifications
You must be signed in to change notification settings - Fork 6
Pull requests: astronomy-commons/adc-streaming
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
Add support for sending messages with keys
enhancement
New feature or request
#70
by cnweaver
was merged Feb 17, 2025
Update doc strings and comments for confluent-kafka workarounds
#68
by lpsinger
was merged May 22, 2023
Update confluent-kafka version to skip recent buggy releases
#67
by lpsinger
was merged May 22, 2023
Allow specifying logical offset or datetime start position on Consumer.stream()
#65
by alchzh
was merged Oct 4, 2023
Modify error callback to warn about TIMED_OUT error
#59
by deepchatterjeeligo
was closed Nov 16, 2022
Loading…
add a stop method to the consumer class; address #57
#58
by deepchatterjeeligo
was merged Aug 31, 2022
Loading…
Do not raise exceptions inside the logging callback
#52
by cnweaver
was merged Dec 15, 2021
Loading…
Avoid crashing when a new message is published to a partition the end of which had previously been reached
#51
by cnweaver
was merged Feb 22, 2022
Loading…
consumer.py: allow multiple topics to be passed into subscribe()
#47
by myNameIsPatrick
was merged Aug 27, 2021
Loading…
Expose more Kafka options for reliable message transmission
#44
by cnweaver
was merged Jul 9, 2021
Loading…
Expose low-level Kafka error details through KafkaException
#43
by spenczar
was merged Jun 3, 2021
Loading…
Obey offsets stored in Kafka for existing groups
#42
by myNameIsPatrick
was merged Aug 19, 2020
Loading…
Previous Next
ProTip!
What’s not been updated in a month: updated:<2025-01-19.