kafka-consumer-api

0зной

1ответ

Почему метаданные добавляются на выход этого разъема Kafka?

У меня есть соединитель Kafka со следующим кодом для метода poll() в реализации SourceTask. @Override public List<SourceRecord> poll() throws InterruptedException { SomeType item = mQueue.take(

0зной

1ответ

InstanceAlreadyExistsException, исходящий от потребителя kafka

Я работаю с Kafka и пытаюсь настроить группу потребителей, обращаясь к этому article. Единственное различие заключается в том, что я создал свой собственный абстрактный класс, обработчик для упрощения

0зной

1ответ

Потребность в потребительской корзине Kafka, полученная в пакете

Я искал у потребителя партии Kafka, и я не нашел ценной информации. использования: Производитель будет производить данные очень часто и на потребительском сайте мы будем использовать данные и от потре

1зной

1ответ

Многопоточный потребитель или потребительский продукт Kafka

Какой должен быть лучший подход при внедрении потребителя кафки. Задача считывается с Kafka и записывается обратно в db. Миллионы рядов Подход 1: За раздел - для потребителя - Подождите, пока сообщени

0зной

1ответ

Kafka Consumer Cluster Environment Offset

Я пытаюсь, чтобы x число пользователей обращалось к определенной теме в kafka, но не потребляло одни и те же сообщения. Я хочу, чтобы к примеру ... Потребитель 1 выбирают вверх смещение 1 Потребитель

5зной

2ответ

KafkaConsumer 0.10 Сообщение об ошибке Java API: нет текущего назначения для раздела

Я использую KafkaConsumer 0.10 Java api. Я хочу потреблять из определенного раздела и определенного смещения. Я поднял глаза и обнаружил, что существует метод поиска, но он бросает исключение. У кого-