feat: fix

This commit is contained in:
2025-04-09 15:31:10 +03:00
parent d27390426c
commit 00c112b20d

View File

@@ -6,15 +6,15 @@ from backend.session import session_maker
from external.kafka.context import context
from external.kafka.services.consumer_service import ConsumerService
consumer = AIOKafkaConsumer(
KAFKA_CONSUMER_TOPIC,
bootstrap_servers=KAFKA_URL,
security_protocol='SSL',
ssl_context=context,
)
async def consume_messages():
consumer = AIOKafkaConsumer(
KAFKA_CONSUMER_TOPIC,
bootstrap_servers=KAFKA_URL,
security_protocol='SSL',
ssl_context=context,
)
try:
await consumer.start()
except KafkaConnectionError as e: