Где хранятся разделы Kafka и соответствующие смещения при использовании сообщений от Kafka с использованием Apache Storm Trident?Я мог найти что-то в Storm Zookeeper под ls /transactional/<StreamName>/coordinator/meta.Но я не могу понять, что это за смещения и к какому разделу они относятся?Как я могу проверить Consumer Lag при работе с топологией Trident?