Кто-нибудь опубликовал ответ на эту проблему?Были и другие посты без ответов.Наша ситуация...
Рассмотрим следующие реальные запутанные журналы: 19:33:48,409 99733391 (pool-6-thread-11) ERROR...
Я пишу клиенту Kafka как: public class BasicProducerExample { public static void main(String[]...
Я пытаюсь опубликовать данные из Nifi 1.7.1 в Kafka 0.10 через SASL_Plaintext.Мы уже проверяли, что...
Я создаю потоковое задание, которое читает две темы кафки и пишет в одной теме кафки.Я работаю с...
Попытка вернуть сообщение через библиотеку rkafka в R. Следовал той же документации rkafka @...
Я использую Кафку 0.11. Я не нахожу класс StoreBuilder в kafka-streams-0.11.0.0.jar. Есть идеи, в...
Я использую spring-kafka для опроса сообщения, когда я использую аннотацию для потребителя и...
Я только начал с простого примера, чтобы прочитать метрики jmx, и использовал простые значения...
Я пишу докеризованное приложение Java 9 Spring с использованием Apache Storm 1.1.2, Apache Kafka 0
Я пытаюсь использовать информацию из темы __consumer_offsets, так как казалось, что это может быть...
Я хочу использовать SSL-шифрование и аутентификацию, но у нас много клиентов, и мы не хотим...
Я попытался подключиться к нескольким базам данных, включая MySQL и MSSQL, и у меня не было проблем
У меня проблемы с сервисом, который использует весенний облачный поток и кафку. Служба работала...
Я использую процессор KafkaPublish для публикации сообщений в теме kafka, защищенной с...
У меня есть производитель, который передает данные, которые мы будем использовать для тестирования...
Я новичок в Kafka, и мой вариант использования: у меня есть резервный кластер Kafka 3node, и если я...
Я пытаюсь создать многоузловой кластер Apache Kafka с помощью Docker Swarm. Для этого я использую...
Я новичок в Кафе, но у меня есть опыт работы с ActiveMQ.Когда я читаю о Кафке, я понимаю, что в...
Вот ситуация: у меня есть несколько тем kafka, которые содержат сообщения, соответствующие детям, и...
У меня есть потребитель, подписавшийся на тестовую тему, где ветка продюсера регулярно публикует...
У меня есть процесс, который должен отправить определенные данные на кластер Flink (через kafka),...
Я пытаюсь установить log.retenton.hours для конфигурации уровня брокера для kafka 0.10.2x. Но я...
В настоящее время поток данных архитектуры выглядит следующим образом: Вариант использования # 1...
Мы используем соединитель Kafka-Mqtt от команды Confluent. Есть ли способ опубликовать данные из...