AioKafkaFastProducer
faststream.kafka.publisher.producer.AioKafkaFastProducer #
Bases: ProducerProto
A class to represent Kafka producer.
Source code in faststream/kafka/publisher/producer.py
publish async
#
publish(message, topic, *, correlation_id, key=None, partition=None, timestamp_ms=None, headers=None, reply_to='', no_confirm=False)
Publish a message to a topic.
Source code in faststream/kafka/publisher/producer.py
stop async
#
publish_batch async
#
publish_batch(*msgs, correlation_id, topic, partition=None, timestamp_ms=None, headers=None, reply_to='', no_confirm=False)
Publish a batch of messages to a topic.