AsyncAPIBatchPublisher
faststream.confluent.publisher.asyncapi.AsyncAPIBatchPublisher #
AsyncAPIBatchPublisher(*, topic, partition, headers, reply_to, broker_middlewares, middlewares, schema_, title_, description_, include_in_schema)
Bases: BatchPublisher
, AsyncAPIPublisher[Tuple['ConfluentMsg', ...]]
Source code in faststream/confluent/publisher/usecase.py
publish async
#
publish(message, *extra_messages, topic='', partition=None, timestamp_ms=None, headers=None, correlation_id=None, reply_to='', no_confirm=False, _extra_middlewares=())
Source code in faststream/confluent/publisher/usecase.py
request async
#
request(message, topic='', *, key=None, partition=None, timestamp_ms=None, headers=None, correlation_id=None, timeout=0.5, _extra_middlewares=())
Source code in faststream/confluent/publisher/usecase.py
setup #
add_prefix #
schema #
Returns the schema of the API operation as a dictionary of channel names and channel objects.
add_middleware #
create staticmethod
#
create(*, batch, key, topic, partition, headers, reply_to, broker_middlewares, middlewares, schema_, title_, description_, include_in_schema)
Source code in faststream/confluent/publisher/asyncapi.py
get_name #
get_description #
get_schema #
Source code in faststream/confluent/publisher/asyncapi.py
get_payloads #
Source code in faststream/broker/publisher/usecase.py
set_test #
Turn publisher to testing mode.