Как посмотреть временную метку создания и изменения темы в Кафке

Question

Или хотя бы один из них?Я не понимаю, когда использую kafka-topics.sh --list или --describe, возможно, мне не хватает опции для многословия, хотя я вообще не вижу их в списке атрибутов для конфигурации темы.Разве это не разумная информация с Кафкой?

Answer 1

Вы можете увидеть время создания темы Kafka (ctime) и время последнего изменения (mtime) в zookeeper stat.

Первый вход в оболочку zookeeper

kafka % bin/zookeeper-shell.sh localhost:2181 stat /brokers/topics/test-events

Она вернется ниже деталей:

Connecting to localhost:2181

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
cZxid = 0x1007ac74c
ctime = Thu Nov 01 10:38:39 UTC 2018
mZxid = 0x4000f6e26
mtime = Mon Jan 07 05:22:25 UTC 2019
pZxid = 0x1007ac74d
cversion = 1
dataVersion = 8
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 112
numChildren = 1

Вы можете сослаться на это, чтобы понять атрибуты: https://zookeeper.apache.org/doc/current/zookeeperProgrammers.html#sc_zkStatStructure

Answer 2

Kafka публично не объявляет дату создания / изменения темы.

Для работы самих данных синхронизации Kafka не требуется.Текущие значения конфигурации темы хранятся в ансамбле Zookeeper, который необходим для функционирования всего кластера Kafka, поэтому он синхронизируется основным процессом zookeeper, а для той части, которую Kafka требуется синхронизировать, только смещения в теметребуется частично упорядочить сообщения по мере их поступления, отметка времени не является обязательной информацией.

Если вы хотите, чтобы изменения темы выполнялись, возможно, вам лучше всего иметь тему Kafka для сохранения таких изменений, чтобы вы моглипозже могу прочитать.