Почему сервер Karafka выдает ошибку смещения водяного знака запроса?

Question

Я использую этот драгоценный камень в своих приложениях Ruby on Rails для создания и получения сообщений с сервера Kafka. https://karafka.io/docs/

а это мой файл karafka.rb

      # frozen_string_literal: true

class KarafkaApp < Karafka::App
  setup do |config|
    config.kafka = {"bootstrap.servers": ENV["KAFKA_BOOTSTRAP_SERVERS"]}
    config.client_id = "store"
    config.consumer_persistence = !Rails.env.development?
  end

  Karafka.monitor.subscribe(Karafka::Instrumentation::LoggerListener.new)
  
  Karafka.producer.monitor.subscribe(
    WaterDrop::Instrumentation::LoggerListener.new(Karafka.logger)
  )

  Karafka.monitor.subscribe "error.occurred" do |event|
    type = event[:type]
    error = event[:error]
    details = (error.backtrace || []).join("\n")

    puts "Oh no! An error: #{error} of type: #{type} occurred!"
    puts details
    puts "=" * 100
    NewRelic::Agent.notice_error(error)
  end

  routes.draw do
    topic "payment-order" do
      consumer PaymentOrderConsumer
    end

    topic "payment-method-config" do
      consumer PaymentMethodConsumer
    end

    topic "order-refund" do
      consumer OrderRefundConsumer
    end
  end
end

Karafka::Web.enable!

Спустя некоторое время я получил эту ошибкуError querying watermark offsets for partition 0 of karafka_consumers_states - Local: Unknown partition (unknown_partition) Потребитель по-прежнему без проблем принимает новое сообщение, но я периодически получаю ошибку выше.

Я не нашел другой ошибки в Google.

Я пробовал установить bash и librdkafka на сервер. Использование только 1 сервера начальной загрузки Kafka.

Эта тема уже присутствует на сервере Kafka.

Answer 1

Я автор Карафки.

Вы невнимательно следовали инструкциям. Для веб-интерфейса требуется начальная загрузка: https://karafka.io/docs/Web-UI-Getting-Started/

Пункт 3:

Запустите следующую команду, чтобы установить karafka-web в ваш проект:

bundle exec karafka-web install

Без этого веб-интерфейс Karafka не сможет обеспечить работу ожидаемых данных.

Вы можете либо запустить установку, либо отключить веб-интерфейс. Выбор ваш.

Веб-интерфейс Karafka предоставляет страницу состояния, которая может помочь вам выявить и устранить проблемы, которые могут привести к сбоям или неправильному поведению веб-интерфейса. Если вы видите страницу 404 или у вас возникли проблемы с веб-интерфейсом Karafka, стоит посетить эту страницу.