Как получить информацию о разделе и смещении для темы Kafka, не зная информацию о группе потребителей

Я полностью приседаю в Kafka земля Если я управляю командой

/cfintools/confluent-4.0.0/bin/kafka-avro-console-consumer --topic $t  --bootstrap-server  $bt  --consumer.config /cfintools/avro_consumer_ssl_cfin_prod.properties --property schema.registry.url=$regd --from-beginning

вещь просто вечна, чтобы вернуться. Нет ошибки, но нет данных.
Все, что я хочу, это последние 10 сообщений в этой теме, и я читаю о partition а также offsets, Теперь я не знаю, как мир должен получить эту информацию. В другом месте, где я читал об этой команде.

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group count_errors --describe

Но я не знаю свою группу потребителей. Я просто знаю topic name и другие параметры, упомянутые в 1-ой команде. Итак, с помощью этой ltd информации, как мне получить последние 10 нечетных сообщений в теме, ищущих только определенный раздел и смещение или любым другим способом

Я пытался использовать kt инструмент

$  ./kt topic -brokers $bk -filter $t -partitions -leaders -replicas
failed to create client err=kafka: client has run out of available brokers to talk to (Is your cluster reachable?)

Я знаю, что брокеры действительны, потому что я их использую

Что я хочу любезно:

  • получить partition и смещается самым простым способом без какой-либо дополнительной информации, такой как группа потребителей
  • Любой другой подход для автоматического поиска последних 10 messages - этот раздел и смещение и выборка
  • любой инструмент на основе графического интерфейса, который помешает мне сойти с ума
Источник

0 ответов

Другие вопросы по тегам