apache-kafka

0зной

1ответ

Я искал пакеты для узла, как это: https://www.npmjs.com/package/kafka и https://www.npmjs.com/package/no-kafka Мой вопрос: Есть ли эти пакеты делает node.js подписаться на Кафку все время? или Мне нуж

1зной

1ответ

Как подписаться на тему в apache kafka из приложения java?

Это потребитель для Apache Kafka и он не получает сообщения из темы «тест» package com.kafka; import java.util.Arrays; import java.util.Properties; import org.apache.kafka.clients.consumer.Consum

0зной

1ответ

Ошибка с инструментом kafka Mirrormaker [kafka version 0.10]

Я пытаюсь использовать инструмент Mirrormaker для репликации данных из одного основного кластера в резервный, но я получил следующую ошибку. nykpsr000001726$ bin/kafka-mirror-maker.sh --consumer.confi

1зной

1ответ

Как обрабатывать сообщения в формате avro от Kafka?

Я пытаюсь реализовать ниже команду kafka-console-consumer (хорошо работает & выводит нужные данные json) в виде программы с использованием искровой потоковой передачи. kafka-console-consumer.sh --zook

0зной

1ответ

Сколько записей хранится в каждом смещении раздела kafka?

я наткнулся ниже Кафка официального заявления По каждой теме кластер Кафки поддерживает многораздельное бревно Каждого раздел представляет собой упорядоченная, неизменная последовательность записей, к

6зной

1ответ

Как обрабатывать ошибки и не совершать при использовании Kafka Streams DSL

Для потоков Kafka, если мы используем API-интерфейс более низкого уровня, мы можем управлять фиксацией или нет. Поэтому, если в нашем коде возникают проблемы, и мы не хотим передавать это сообщение. В