0.6.0 #1779
Draft
0.6.0 #1779
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* fix: Non-threadsafe operations in AsyncConfluentProducer. * fix: Unbound error in AsyncConfluentProducer.publish method. * fix: AsyncConfluentFastProducer type hints.
* feat: Mypy tests for broker middleware. * refactor: Move BaseMiddleware to _internal module. * fix: Added missed second type variable to BrokerMiddleware protocol. * fix: Broker middleware mypy issues. * fix: Added missed type vars to base prometheus middleware classes. * fix: Redis prometheus middleware type hints. * fix: Rabbit prometheus middleware type hints. * fix: Nats prometheus middleware type-hints. * fix: Kafka broker public middleware contract. * fix: Confluent broker middleware public contract. * fix: Confluent prometheus middleware type hints. * fix: Kafka pometheus middleware type hints. * fix: Linter issues.
* chore: merge main * tests: new Listener tests * chore: refactor CincurrentBetwwenPartitionsSubscriber * chore: refactor CincurrentBetwwenPartitionsSubscriber * fix: correct ConcurrentManualAckSubscriber behavior * tests: increase timeout in kafka concurrent tests * refactor: change ListenerProxy logic * tests: increase workers number for kafka
|
|
* feat: rabbit subscriber iterator * test: rabbit subscriber iterator * test: use async for loop for test async iterator * feat: add __aiter__ method in SubscriberProto * fix: return RabbitMessage everytime, ignore override * feat: kafka subscriber iterator * feat: add subscriber iterator for nats * feat: add subscriber iterator for redis * feat: add subscriber iterator for confluent * fix: type hint fixes and formatting * fix: type hint fixes and formatting * test: add test iterator in base consume * test: add test iterator for nats js, kv, os and etc * test: add test iterator for redis list and stream * chore: fix typo --------- Co-authored-by: Pastukhov Nikita <nikita@pastukhov-dev.ru>
|
@fdsflksdk777 can you sign the CLA – #1779 (comment) please? |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description
Please include a summary of the change and specify which issue is being addressed. Additionally, provide relevant motivation and context.
fixes #1742 close #1228, close #980, fixes #1742, #1895 feature, fixes #1954, close #1646, fixes #1625, close #1904, close #1507, close #2056, close #1308, close #1901, close #2029, close #2094, close #1881
Breaking changes:
@broker.subscriber(..., filters=...)removedmessage.decoded_bodyremoved, useawait message.decode()insteadpublish(..., rpc=True)removed, usebroker.request()instead@broker.subscriber(..., reply_config=...)removed, useResponseinsteadContext("broker")andContext("logger")moved to local context. They can not be accessed in lifespan hooks anymoreFastStream(broker)is positional-only argument now (preparing toFastStream(*brokers)support)FastStream(**asyncapi_options)doesn't work anymore. Now, you have to create specialAsyncAPI(broker, **asyncapi_options)to render documentationFastStream(broker)is POSITIONAL-ONLY option now.FastStream(broker=broker)doesn't work anymorebroker.subscriber(..., retry=True)removed, useack_policyinstead