Thành phố Cuồng loạn

Giới thiệu AIOKafkaProducer là client bất đồng bộ dùng để xuất bản bản ghi lên cụm Kafka. Các ví dụ dưới đây được viết cho aiokafka 0.8+ và Python 3.8 trở lên, sử dụng asyncio.run thay vì truyền loop trực tiếp. Gửi một tin nhắn đơn Khi tạo producer, gọi start(), gửi tin bằng send_and_wait(), rồi dừng producer trong khối finally. import asyncio ...