Когда я пытаюсь соединить сливной кластер Kafka с простым потребительским кодом, используя Scala....
Обратите внимание, что я уже много читал следующую статью и пытался найти нужную информацию на...
В моем приложении верблюда у меня есть простой маршрут, использующий одну тему кафки, задающий...
У меня есть кластер из 3 брокеров Kafka с коэффициентом репликации 3 для всех тем.Так как последние...
Я хотел бы узнать преимущества, которые приходят к Кафке от преобразования данных в двоичные...
Я сталкиваюсь с org.apache.kafka.common.errors.InvalidGroupIdException: Чтобы использовать API...
Чтобы вычислить сложный алгоритм для огромного набора данных, мы хотим использовать MQ, такой как...
Я работаю над приложением, которое должно создать базу данных, используя данные, хранящиеся в...
Используя шаблон Spring Kafka, у меня есть 2 разных производителя, которые отправляют разные...
Я хочу передать данные из облачного приложения, которое будет публиковать журналы в разделах Kafka...
У меня есть тема, состоящая из 5 разделов: p[0] offset: 492453047 p[1] offset: 122642552 p[2]...
После неожиданного закрытия брокеров некоторые тематические разделы остаются в автономном режиме,...
Предположим, у меня есть тема под названием "пакетная обработка" с 1 разделом, и я публикую в ней...
Добрый день, коллеги. Я использую Spring Kafka 2.2.5 У меня есть слушатель: @KafkaListener(topics =...
Я пытаюсь настроить межброкерскую SSL (не клиентскую) аутентификацию и постоянно вижу следующие...
Мне было интересно, есть ли быстрый способ дублировать группу потребителей Kafka. Допустим, есть...
Мне нужны предложения альтернатив Spring-Kafka. Я использовал Kafka, интегрированный в Spring, в...
Мне нужно отловить исключения в случае асинхронной отправки в Кафку.Api-производитель Kafka...
Я делаю проект, используя springboot 2, kafk 2.2.0, spring-kafka 2.2.5 Я создал kafka exactly once...
Я добавил два столбца в свою таблицу, затем я запускаю планировщик в vertica, но vertica не...
Я работаю над сценарием, в котором мой код производителя kafka будет находиться на машине с Windows...
Хотите получить потоковые журналы через потребителя, а затем сохранить их в Cassandra с помощью...
Я только начинаю с Kafka, это звучит очень хорошо для Microservices, но я работаю в основном в...
Я пытался использовать некоторые улучшения в Kafka Connect в версии 2.0.0, как указано в этом KIP...
Я реализую конечную точку в весенней загрузке, которая при вызове будет делать дамп всех сообщений,...