Автообнаружение по json файлу или api json

[Cholovskiy]

Приветствую коллеги! Есть вот такая задача, есть сервер Kafka, разработчики создали API которое по post запросу отдает вот такие данные, (смотрите ниже)
Я читал документацию, но так и не понял, как мне создать правила автообнаружения что бы автоматом у меня заводился {#TOPIC_NAME}": "push_callback_retry с пренадлежащими соответсвено ему данными "{#END_OFFSET}": 0,
"{#CURRENT_OFFSET}": 0,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
Прошу помощи у сообщества. Как добиться решения поставленной задачи.
Так как данные push_callback_retry могут появляться или удаляться, они не статичны.





{
"data": [
{
"{#TOPIC_NAME}": "push_callback_retry",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 0,
"{#CURRENT_OFFSET}": 0,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "smpp_server_dr",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 0,
"{#CURRENT_OFFSET}": 0,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "dr_push_delay_queue",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 63715,
"{#CURRENT_OFFSET}": 63715,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "send_push_transacted",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 142973,
"{#CURRENT_OFFSET}": 142973,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "kafka-monitor-topic",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 0,
"{#CURRENT_OFFSET}": 0,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "send_to_sms_32",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 0,
"{#CURRENT_OFFSET}": 0,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "dr_sms_delay_queue",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 4760,
"{#CURRENT_OFFSET}": 4760,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "send_to_sms_30",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 34,
"{#CURRENT_OFFSET}": 34,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "scheduled_messages",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 229113,
"{#CURRENT_OFFSET}": 229113,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
},
{
"{#TOPIC_NAME}": "send_viber_no_transacted",
"{#PARTITIONS}": [
{
"{#END_OFFSET}": 2,
"{#CURRENT_OFFSET}": 2,
"{#PARTITION}": 0,
"{#MESSAGES_COUNT}": 0
}
]
}
]
}