Почему потребительские показатели Kafka медленные?

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

kafka.consumer.SimpleConsumer: переподключение из-за ошибки сокета: java.nio.channels.ClosedChannelException

Я использую простой потребитель для кафки, такой как этот:

@matthias j sax

дняя версия kafka поддерживает семантику «точно один раз» (EoS). Чтобы поддержать это понятие, дополнительные детали добавляются к каждому сообщению. Это означает, что у вашего потребителя; если вы печатаете смещения сообщений, они не обязательно ...

Как происходит перебалансирование потребителей в Кафке?

Когда новый потребитель / посредник добавляется или выходит из строя, Kafka запускает операцию восстановления баланса. Является ли Кафка ребалансировкой опер...

Kafka Consumer не получает сообщения

Я новичок в Кафке. Я прочитал много инструкций в Интернете, чтобы сделать Kafka Producer и Kafka Consumer. Я сделал первый успешно, который может отправлять ...

разница между groupid и consumerrid в Kafka

Я новичок в Кафке. Я заметил, что в конфигурации Consumer есть два идентификатора. один - group.id (обязательный), а второй - consumer.id (не обязательный). ...

Kafka Avro Consumer с проблемами декодера

Когда я попытался бежатьКафка Потребительская с Авро поверх данных с моей соответствующей схемой возвращает ошибку «AvroRuntimeException: искаженные данные. ...

JBOSS дает org.apache.kafka.common.KafkaException: auth.conf не может быть прочитан

Кафка: Изменить количество разделов для конкретной темы, используя Java

Я новичок в Kafka и работаю с новыми KafkaProducer и KafkaConsumer, версия: 0.9.0.1Есть ли способ в Java, чтобы изменить / обновить количество разделов для к...

Kafka 0.9.0.1 Java Consumer застрял в awaitMetadataUpdate ()

Я пытаюсь заставить простого Kafka Consumer работать с использованием Java API v0.9.0.1. Сервер kafka, который я использую, является док-контейнером, также р...