Я пытаюсь интегрировать EmbeddedKafka (https://github

val a = keyedPatStream.map(_._1)//String val b = keyedStream.map(_._1)//String val c =...

Я использую потребитель Kafka с Flink 1.9 (в Scala 2.12) и сталкиваюсь со следующей проблемой...

У меня проблемы с настройкой Kafka Producer для использования SSL. Мое приложение развернуто на...

Для целей миграции нам нужно создать записи, используя два разных сериализатора и, следовательно,...

Если я использую свойство listener.concurrency, будет ли это использовать...

Можно ли использовать Confluent Kafka JDBC connect в кластере Apache Kafka? Я пытаюсь использовать...

У меня есть 2 потока kafka один (keyedStream) для DataStream позже (keyedPatStream) для Pattern...

Я пытаюсь получить экземпляр kafka внутри контейнера докера. Docker-compose.yml выглядит так:...

Я пытаюсь добавить kafka-mongo-connector в kafka-connect, чтобы быть источником событий. Я...

Я работаю с Java-производителем и потребителем, я пытаюсь визуализировать свое потребительское...

В настоящее время я отправляю данные с использованием spring-kafka следующим образом: val json =...

Я пытаюсь понять причину, по которой существующее приложение, использующее kafka-2-1-4, развернутое...

Я пытаюсь прочитать запрошенное количество сообщений kafka в обратном порядке. Поскольку существует...

Я завершил 2 рукопожатия SSL и пытаюсь завершить часть ACL. Когда я запускаю свой сервер: я получаю...

Я новичок в весенне-интеграционной кафке. Я настраиваю Кафку на Docker, но не могу создавать и...

Моя проблема У меня есть один производитель. создайте сообщение дважды «hello1», «hello2» для имени...

Я хочу использовать Apache Kafka Connect, чтобы получать твиты из Twitter и помещать их в мой...

Почему apache kafka допускает только добавления, но не удаления разделов в темах. Как это работает...

Я хочу использовать zookeeper (3.5.5) с kerberos (активный каталог). Пользователь с UPN...

Я начал изучать кафку. Я не очень представляю себе живой проект, где используется кафка. Хотите...

Я пытаюсь выучить Кафку, это команда, которую я видел для создания темы. bin/kafka-topics.sh...

У меня проблема с сервером приложений spring-boot (2.1.7.RELEASE), который использует библиотеку...

У меня есть этот код, который дает locationID и temp, я хочу шаблон, который выдает предупреждение...

Мы работаем над добавлением детализации SQLEngine - Apache поверх Kafka и включаем доступ к...