Я полностью приседаю на 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 и другие параметры, упомянутые в 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 - этот раздел и смещение и выборка - любого графического интерфейса пользователяинструмент, который не даст мне сойти с ума