astronomy-commons adc-streaming issues

astronomy-commons / adc-streaming

Core Python(ic) client libraries and utilities for alert streaming

BSD 3-Clause "New" or "Revised" License

6 stars 6 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Multi-topic publishing

#69 cnweaver closed 4 months ago
0
Update doc strings and comments for confluent-kafka workarounds

#68 lpsinger closed 1 year ago
1
Update confluent-kafka version to skip recent buggy releases

#67 lpsinger closed 1 year ago
3
Consumer behavior when topic doesn't exist on broker

#66 cmessick opened 1 year ago
2
Allow specifying logical offset or datetime start position on Consumer.stream()

#65 alchzh closed 1 year ago
8
Revert compression to being off by default

#64 cnweaver closed 1 year ago
1
Update FIXME comments

#63 lpsinger closed 2 years ago
0
Add message_max_bytes producer option

#62 lpsinger closed 2 years ago
0
Set producer compression type to zstd

#61 lpsinger closed 2 years ago
2
Add pyproject.toml file for PEP 517 builds

#60 lpsinger closed 2 years ago
3
Modify error callback to warn about TIMED_OUT error

#59 deepchatterjeeligo closed 1 year ago
4
add a stop method to the consumer class; address #57

#58 deepchatterjeeligo closed 2 years ago
2
Consumer does not shutdown when running in a different thread

#57 deepchatterjeeligo closed 1 year ago
5
Work around librdkafka crash when using oauth_cb

#56 lpsinger closed 2 years ago
4
Kafka exception catch

#55 areeda closed 2 years ago
0
Problem handling Kafka exceptions

#54 areeda opened 2 years ago
16
Add OAUTHBEARER/OIDC support

#53 lpsinger closed 2 years ago
17
Do not raise exceptions inside the logging callback

#52 cnweaver closed 2 years ago
0
Avoid crashing when a new message is published to a partition the end of which had previously been reached

#51 cnweaver closed 2 years ago
1
Version for new release?

#50 myNameIsPatrick closed 3 years ago
3
Use setuptools_scm for version management

#49 myNameIsPatrick closed 3 years ago
1
Set delivery callbacks per-message, not per-client

#48 cnweaver closed 3 years ago
3
consumer.py: allow multiple topics to be passed into subscribe()

#47 myNameIsPatrick closed 3 years ago
4
Add support for sending messages with headers

#46 cnweaver closed 3 years ago
0
Refactor consumer auto-commit

#45 cnweaver closed 3 years ago
0
Expose more Kafka options for reliable message transmission

#44 cnweaver closed 3 years ago
1
Expose low-level Kafka error details through KafkaException

#43 spenczar closed 3 years ago
0
Obey offsets stored in Kafka for existing groups

#42 myNameIsPatrick closed 4 years ago
4
ConsumerStartPosition.PRODUCER not handled properly in Consumer

#41 myNameIsPatrick closed 4 years ago
4
Outdated versions on conda SCiMMA channel

#40 myNameIsPatrick opened 4 years ago
0
setup.py, meta.yaml: remove fastavro dependency as it's no longer used

#39 myNameIsPatrick closed 4 years ago
0
consumer.py: fix version display in log warnings if using latest offsets

#38 myNameIsPatrick closed 4 years ago
0
producer.py: increase producer timeout to 10s

#37 myNameIsPatrick closed 4 years ago
1
Rewrite API

#36 spenczar closed 4 years ago
6
Miscellaneous decrufting and cleanup.

#35 spenczar closed 4 years ago
0
Refactor config loading

#34 spenczar closed 4 years ago
1
Fix certifi config loading

#33 spenczar closed 4 years ago
0
Raise error messages

#32 spenczar closed 4 years ago
0
Use certifi by default

#31 spenczar closed 4 years ago
0
Fix Avro stream parsing

#30 spenczar closed 4 years ago
0
Processing avro-formatted streams appears broken

#29 ebellm closed 4 years ago
1
Add a GH Workflow for CI

#28 spenczar closed 4 years ago
0
Look into submitting adc-streaming for inclusion to conda-forge

#27 mjuric opened 4 years ago
5
Add docker-based integration test

#26 spenczar closed 4 years ago
2
Rewrite parse_kafka_url and add tests for it

#25 spenczar closed 4 years ago
6
Rename project to adc-streaming

#24 spenczar closed 4 years ago
5
Rewrite `AlertBroker._committed`

#23 spenczar closed 4 years ago
13
Remove HEARTBEAT_SENTINEL

#22 spenczar closed 4 years ago
5
Split reading and writing into two different classes

#21 spenczar closed 4 years ago
3
Run autopep8

#20 spenczar closed 4 years ago
0