Я пытаюсь использовать ruby-kafka https://github.com/zendesk/ruby-kafka, и я использую его следующим образом:
kafka = Kafka.new(["abc123d.xyz.cde.net:9093",
"abc123f.xyz.cde.net:9093",
"abc123h.xyz.cde.net:9093",
"abc123k.xyz.cde.net:9093"
],
sasl_gssapi_keytab: '/etc/krb5.keytab',
sasl_gssapi_principal: 'abc09123@SOMETHING.ETED.NET'
sasl_over_ssl: false)
kafka.deliver_message("Hello, World!", topic: "TestTopic")
Когда я проверяю это, я получаю ошибку
NameError: undefined local variable or method
min_stat 'для # Вы имели в виду?maj_stat`
Почему я все еще получаю эту ошибку?
Fetching cluster metadata from kafka://abc123d.xyz.cde.net:9093
Opening connection to abc123d.xyz.cde.net:9093 with client id ruby-kafka...
Sending sasl_handshake API request 1 to abc123d.xyz.cde.net:9093
Waiting for response 1 from abc123d.xyz.cde.net:9093
Received response 1 from abc123d.xyz.cde.net:9093
GSSAPI: Initializing context with abc123d.xyz.cde.net:9093, principal abc09123@SOMETHING.ETED.NET
NameError: undefined local variable or method `min_stat' for #<GSSAPI::Simple:0x00007fdceb7f0f88>
Did you mean? maj_stat