Я пытался использовать набор состояний для развертывания сервера zookeeper и Kafka в кластере в gke...
Из https://micronaut -projects.github.io / micronaut-kafka / latest / guide / # kafkaStream , я...
Привет, у меня есть 3 потока событий, которые я хочу объединить, используя потоки Kafka. Я не могу...
Я хочу иметь возможность читать сообщения, приходящие в определенные разделы темы, а также...
Мы используем KAfka Broker 2.10 и Kafka java driver 2.0.1 и Kafka Stream Driver 2.0.1. Мы...
У меня есть приложение для потоковой передачи kafka, которое отображает / преобразует сообщение...
У нас была уплотненная тема с одним разделом, и мы добавили в нее один новый раздел. Мы не...
У меня возникли проблемы с созданием SerDes для использования с данными, которые я собираю, и мне...
Мы используем Azure DataLake Storage 2. Файл .jar, чтобы обеспечить его работу, требует...
Я пытаюсь настроить кластер kafka на платформе Openshift, используя это руководство:...
У меня есть Java-приложение, использующее dropqizard + maven, и я внедрил производителей и...
У меня есть архитектура, в которой у нас есть два отдельных приложения. Первоначальный источник -...
Я получаю Ошибка смещения фиксации в разделе app-KSTREAM-MAP-0000000017-repartition-2 со смещением...
Я хочу знать отставание потребителей для группы потребителей, использующих Java. Я пытался...
Я пытаюсь создать оконное хранилище из набора точек данных, но похоже, что ветвь топологии потока...
У меня есть записи, которые обрабатываются с помощью Kafka Streams (с помощью Processor API)
Исключение пространства кучи из памяти исключение при десериализации сообщения Avro в потребителе...
Вот что я пытаюсь сделать: Я пытаюсь использовать сообщения в 5-минутном временном окне и...
Можно ли в Kafka Stream API пересылать более одной записи одновременно разным дочерним процессорам?...
Я использую соединитель Alpakka kafka для приема пакетов от kafka. Я использую Consumer в качестве...
Можно ли использовать интерактивный запрос (InteractiveQueryService) в Spring Cloud Stream для...
Я работаю с пружинной интеграцией для передачи данных от конечной точки UDP к кафке. Я...
У меня очень распространенная проблема, но я не могу найти «правильный» или «правильный» способ...
Я хочу создать, перенести и выполнить удаленную отладку приложения Kafka на виртуальной машине...
Я перешел по официальной ссылке , но не получил точно одно окончательное окно окончательных...