Skip to content
Snippets Groups Projects
Commit 65ce509d authored by Waleed Akbar's avatar Waleed Akbar
Browse files

dynamically creates the kafka server address with env variables.

- get the values of KAFKA_NAMESPACE and KFK_SERVER_PORT to create KAFKA server address.
parent cb047522
No related branches found
No related tags found
Loading
...@@ -16,14 +16,18 @@ import logging ...@@ -16,14 +16,18 @@ import logging
from enum import Enum from enum import Enum
from confluent_kafka import KafkaException from confluent_kafka import KafkaException
from confluent_kafka.admin import AdminClient, NewTopic from confluent_kafka.admin import AdminClient, NewTopic
from common.Settings import get_setting
LOGGER = logging.getLogger(__name__) LOGGER = logging.getLogger(__name__)
KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-service.{:s}.svc.cluster.local:{:s}'
class KafkaConfig(Enum): class KafkaConfig(Enum):
KFK_NAMESPACE = get_setting('KFK_NAMESPACE')
KFK_PORT = get_setting('KFK_SERVER_PORT')
# SERVER_IP = "127.0.0.1:9092" # SERVER_IP = "127.0.0.1:9092"
SERVER_IP = "kafka-service.kafka.svc.cluster.local:9092" server_address = KFK_SERVER_ADDRESS_TEMPLATE.format(KFK_NAMESPACE, KFK_PORT)
ADMIN_CLIENT = AdminClient({'bootstrap.servers': SERVER_IP}) ADMIN_CLIENT = AdminClient({'bootstrap.servers': server_address})
class KafkaTopic(Enum): class KafkaTopic(Enum):
REQUEST = 'topic_request' REQUEST = 'topic_request'
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment