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

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

Как настроить ведение журнала для производителей Kafka?

Я использую клиент-производитель Kafka, и у меня нет проекта log4j в моем проекте.При запуске программа печатает много журналов Kafka Debug, которые я действ...

Параметры API для создания тем в Kafka для не-Java языков

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

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

Подходит ли Apache Kafka для использования в качестве неупорядоченной очереди задач?

Кафка разбивает входящие сообщения на разделы в соответствии с разделом, назначенным производителем. Сообщения от разделов затем потребляются потребителями в...

получить тему из сообщения кафки в искре

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

Kafka Нераспознанная опция VM 'PrintGCDateStamps'

Могу ли я создать RDD из темы кафки, если я не знаю смещение до?

Каковы ограничения имени темы Apache Kafka?

Я только что попытался создать тему Кафки