Я установил Kafka " kafka_2.12-0.11.0.0 ". Запущены службы как zookeper , так и Кафка-сервер ....
Мы недавно обновили наших брокеров и клиентов Kafka до версии 1.1.1.После обновления мы...
У меня есть тема с одним разделом и двумя процессами потребителей, которые образуют группу...
Как вы, наверное, знаете, документация Сарамы такая плохая.Ничего не понятноЯ только что нашел этот...
Как это просто, возможно ли Stream Dtream в тему Kafka? У меня есть потоковое задание Spark,...
Я хотел бы иметь семантику "Точно один раз", но я не хочу читать сообщения с помощью Consumer.Я бы...
Как настроить log.cleanup.policy: сжатие с использованием конфигурации пружины
При аутентификации с неверными учетными данными во время аутентификации я получаю следующее...
Может кто-то, пожалуйста, дайте мне хороший пример и взаимосвязь между параметрами kafka...
Я знаю, что каждый раздел выделен одному потребителю Kafka (внутри группы потребителей), но один...
Возможно ли связать клиента cometD с производителем Kafka?Любые предложения? В настоящее время у...
Я создал потребителя, используя следующую зависимость <dependency> <groupId>org.apache
Я пытаюсь записать данные от потребителя Kafka в MySQL, используя JDBC.Я могу взять данные из баз...
Я столкнулся с проблемой в потребителе кафки для обработки исключений.Мой поток: 1) подписаться на...
У меня проблемы с привлечением к работе самого простого потребителя кафки.Я использую...
KafkaConsumer поддерживает как список тем, так и шаблон при подписке. Можем ли мы сделать то же...
Когда я запускаю потребителя с одним экземпляром, он отображается в группе потребителей, но не...
Давайте предположим, enable.auto.commit = true , и давайте предположим, что тема, из которой я...
Существует ли какой-либо подход, позволяющий определить, по какому тарифу потребитель кафки...
Скажите, если интервал автоматической фиксации составляет 30 секунд, потребитель по некоторым...
Пару месяцев я играл с Кафкой (1.0.0) и пытался понять, как работает группа потребителей.У меня...
У меня тут очень странная проблема.Я запустил потребителя Kafka, использующего библиотеку...
пытается соединить два Kstream, но я получаю сообщение об ошибке несоответствия типов, ниже...
После создания «тестовой» темы, kafka-topics --create --zookeeper localhost:2181...
Я столкнулся со странной проблемой, когда мой производитель зеркал может зеркально отображать имя...