remove some files
This commit is contained in:
@@ -1,11 +1,9 @@
|
||||
from confluent_kafka import Consumer, Producer
|
||||
import json
|
||||
import logging
|
||||
from app.utils.logger import logger
|
||||
from app.config import settings
|
||||
import requests
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class KafkaIntegration:
|
||||
_consumer = None
|
||||
|
||||
Reference in New Issue
Block a user