Я новичок в Apache Kafka и немного любитель Ubuntu, на котором я его запускаю (Ubuntu 18.04 и Kafka...

У меня есть потребитель, который получает сообщение от брокера, я хочу выполнить некоторую задачу,...

Хотите вставить значения в столбец, имеющий тип ARRAY. Не нашел ссылки на это в справочном...

Существуют предопределенные SMT Kafka Connect, которые работают в цепочках, но есть ли способ...

Мне понадобилась ровно однажды доставка в моем приложении. Я изучил kafka и понял, что чтобы...

Я новичок в Confluent Kafka и могу запускать Confluent kafka, его производителя и потребителя с...

У меня есть метод прослушивания Kafka, аннотированный @kafkaListener. Он принимает аргумент типа...

Я хочу использовать утилиту командной строки kafkacat (https://docs.confluent

Я хотел бы выяснить, как лучше всего перенаправлять сообщения от Kafka на клиенты веб-сокетов,...

Предположим, координатор группы Kafka назначает приостановленный раздел потребителю. Сможет ли...

Я использую osquery для мониторинга серверов в моей сети. Следующий osquery.conf каждую минуту...

Является ли обычной практикой отправка журналов приложений из серверного приложения в Kafka через...

IBM внутренне отслеживает сервисы, которые предлагаются в облаке, но каким-то образом мне нужно...

Я хочу отправить сообщение Kafka с полезной нагрузкой класса, который расширяется...

Мне трудно реализовать функцию, в которой я могу иметь динамическое значение сообщения для Кафки. Я...

Я настроил kafka_2.11-2.3.0 и apache-zookeeper-3.5.5-bin в Windows 10. Но при выполнении команды...

, когда я использую приведенную ниже команду «/ usr / bin / kafka-delete-records» в брокере Kafka с...

У меня вопрос по поводу Table API в Flink. Я хочу использовать его для создания системы оповещения...

Я создаю производственную среду, в которой у меня будет Apache Kafka. Я хочу знать лучшую...

Я создаю новое настольное приложение в WPF. Целью приложения является чтение данных с устройства и...

У меня есть кластер Apache Kafka с 3-мя брокерами, и я хотел бы определить, когда кластер больше не...

Я пытаюсь отправить сообщение JSON в тему Kafka, используя службу Kafka-rest для сериализации JSON...

После увеличения времени для session_timeout и request_timeout мой потребитель kafka не получает...

Я бы хотел зарегистрировать оба случая, когда сообщение было либо успешно опубликовано, либо по...

У меня есть кластер Kafka с 1.1.1 версией. Недавно я обновил kafka-clients в потребительском...