В весеннем загрузочном проекте с использованием шаблона kafka для отправки сообщения import org
Проблема привязки производителя Kafka 2019-01-04 03: 58: 18.497 ОШИБКА [api-gateway-server ,,,] 1...
Я использую Spring и Kafka, я делаю HTTP-запрос POST, как показано ниже, и отправляю некоторую...
При использовании Integer в качестве ключа это не проблема, kafka должен иметь возможность...
В случае ошибки интерфейс ConsumerAwareErrorHandler предоставляет ссылку на метод ConsumerRecord и...
У меня есть @KafkaListener, который сохраняет новую сущность, используя JDBC-репозиторий Spring...
Я пытаюсь создать простое приложение Kafka Streams, используя среду Spring Cloud Stream.Я могу...
У меня есть одна тема, из которой я могу получать различные типы jsons.Однако, похоже, что я...
Я получаю следующее исключение, потому что я производю из одного проекта, а потребитель потребляет...
Я работаю над POC для реализации кластера kafka в моем проекте.Я установил кластер kafka на моей...
Я пытаюсь опубликовать сообщение для kafka с помощью Spring Boot. Я могу telnet, ping kafka. Я...
У меня есть программа с несколькими потоками, которые обращаются к общему ресурсу.Чтобы избежать...
Я хочу реализовать Aspect, чтобы Кафка читал сообщение с последнего смещения. Я хочу создать...
Я пытаюсь установить специальный конвертер сообщений для моего обработчика сообщений Spring...
Я пытаюсь убедиться, что слушатели kafka закрыты изящно, когда я закрываю свое приложение (изящно...
Есть ли способ добиться поведения приведенного ниже кода с помощью кода, управляемого аннотациями?...
Иногда сообщения могут быть отфильтрованы перед десериализацией на основе значений заголовка
Мой проект реализован весной. Теперь я хочу использовать kafkatemplate.поэтому я добавил ниже...
Наша система kafka вышла из строя из-за отсутствия свободного места на диске.Потребителями являются...
Пытался запустить пример пружинного каркаса версии 2.1.0 и spring.core 3.2.5.Тип org
Это проводной, только что запущенный проект весенней загрузки с простым основным классом, он...
Я получил случай, когда приложение потребляет сообщения и выдает сообщения в ответ на...
Мне трудно понять, как это можно решить, поэтому я спрашиваю об этом здесь в надежде, что кто-то...
При использовании аннотации kafkalistener на уровне класса и указанное свойство обработчика ошибок...
у меня 2 класса;1 для фабрик и другой для контейнеров слушателей: public class ConsumerFactories()...