SERVICE = "kafka"

TOPIC = "kafka.topic"
PARTITION = "kafka.partition"
MESSAGE_KEY = "kafka.message_key"
MESSAGE_OFFSET = "kafka.message_offset"
GROUP_ID = "kafka.group_id"
TOMBSTONE = "kafka.tombstone"
RECEIVED_MESSAGE = "kafka.received_message"

HOST_LIST = "messaging.kafka.bootstrap.servers"

PRODUCE = "kafka.produce"
CONSUME = "kafka.consume"