We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f2fe1eb commit ebef521Copy full SHA for ebef521
aiokafka/__init__.pyi
@@ -1,6 +1,7 @@
1
from .abc import ConsumerRebalanceListener
2
from .consumer import AIOKafkaConsumer
3
from .errors import ConsumerStoppedError, IllegalOperation
4
+from .producer import AIOKafkaProducer
5
from .structs import (
6
ConsumerRecord,
7
OffsetAndMetadata,
@@ -11,6 +12,7 @@ from .structs import (
11
12
__version__ = ...
13
__all__ = [
14
"AIOKafkaConsumer",
15
+ "AIOKafkaProducer",
16
"ConsumerRebalanceListener",
17
"ConsumerStoppedError",
18
"IllegalOperation",
0 commit comments