AsyncAPIPublisher
faststream.confluent.publisher.asyncapi.AsyncAPIPublisher #
AsyncAPIPublisher(*, topic, partition, headers, reply_to, broker_middlewares, middlewares, schema_, title_, description_, include_in_schema)
Bases: LogicPublisher[MsgType]
A class representing a publisher.
Source code in faststream/confluent/publisher/usecase.py
publish abstractmethod
async
#
Publishes a message asynchronously.
Source code in faststream/broker/publisher/proto.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 #
get_description #
get_payloads #
Source code in faststream/broker/publisher/usecase.py
set_test #
Turn publisher to testing mode.
Source code in faststream/broker/publisher/usecase.py
reset_test #
get_name #
get_schema #
Source code in faststream/confluent/publisher/asyncapi.py
create staticmethod
#
create(*, batch, key, topic, partition, headers, reply_to, broker_middlewares, middlewares, schema_, title_, description_, include_in_schema)