В данный момент я играю с Spring Boot 2.1, Spring Kafka (2.2.0) и Micrometer (1.1.0). Я создал...

Я использую spring-kafka 2.1.7 для приема сообщений JSON и хочу обрабатывать сообщения, которые не...

Я хочу отразить некоторые темы от одного брокера к другому. Просто часть всех тем. Для этого...

Я понимаю, что произвольный доступ в неэффективном. Но приложение не удалось, содержимое записи...

У меня запущен и запущен проект Spring Boot с Kafka. Я настроил продюсера и отправил сообщение с...

У меня следующая проблема, может быть, кто-то может подсказать мне, где искать. мой проект: - kafka...

в ответ на мои предложения в ответах на мой предыдущий вопрос Как протестировать...

Я читаю документацию по spring-kafka / kafka взад и вперед и до сих пор не могу найти способ, как...

Trying to configure the Factory as below: private ConcurrentKafkaListenerContainerFactory<Integer...

У нас есть приложение Spring MVC (которое является SAP Hybris), в которое мы хотим интегрировать...

Я хочу прагматически контролировать, когда запускать / останавливать моих слушателей kafka. Поэтому...

Я разработал @KafkaListener, который также помечен интерфейсом ConsumerAwareRebalanceListener,...

Я пытаюсь написать обработчик ошибок для моего приложения Spring Cloud Stream;однако обработчик...

У нас есть 1 тема с 3 разделами с одним потребителем.Мы используем данные в виде пакетов (25),...

Для проекта я использую Spring Cloud Stream с Kafka в качестве связующего для нескольких приложений...

В настоящее время я профилировал приложение весенней загрузки для производителя kafka и обнаружил,...

Я извлекаю строку данных из таблицы в MSSQL, столбец имеет тип «BIT».В реестре схем этот столбец,...

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

Я разрабатываю микросервис, в котором мне необходимо запросить два разных микросервиса с помощью...

Я пытаюсь разработать два класса конфигурации производителя с разными типами сериализации (JSONNode...

Мой проект реализует мультитенантность на уровне Kafka, используя отдельную тему для каждого...

Моя конфигурация для потребителя описана в Документация по свойствам потребителя Spring Cloud...

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

У меня есть служба весенней загрузки, у которой есть потребитель kafka.Я использую spring-kafka для...

Я разрабатываю приложение Spring Boot, которое реагирует на сообщения, помещенные в очередь Kafka....