@staticmethod
def build_inbound_consumer():
    return KafkaConsumer(KAFKA_INBOUND_TOPIC, bootstrap_servers=[KAFKA_BOOTSTRAP_SERVER], auto_offset_reset=KAFKA_INBOUND_AUTO_OFFSET_RESET, enable_auto_commit=False, group_id=KAFKA_INBOUND_GROUP_ID, value_deserializer=(lambda value: json.loads(value.decode(KAFKA_VALUE_ENCODING))))
@staticmethod
def build_inbound_consumer():
    return KafkaConsumer(KAFKA_INBOUND_TOPIC, bootstrap_servers=[KAFKA_BOOTSTRAP_SERVER], auto_offset_reset=KAFKA_INBOUND_AUTO_OFFSET_RESET, enable_auto_commit=False, group_id=KAFKA_INBOUND_GROUP_ID, value_deserializer=(lambda value: json.loads(value.decode(KAFKA_VALUE_ENCODING))))