Таким образом, с приведенной ниже конфигурацией, когда мы масштабируем загрузочные контейнеры...
Когда я перезапускаю свое приложение, мне нужно обрабатывать оставшиеся сообщения в Kafka до тех...
Я создаю обработчик сообщений, который получает событие из одной темы kafka, обрабатывает его и...
Мне нужно записать время, затраченное потребителем на весеннюю кафку.Так как метод kafkaListener...
Я настраиваю ConcurrentMessageListenerContainer <bean class="org.springframework.kafka
Я работаю над загрузочным приложением Spring с spring kafka, которое прослушивает отдельную тему...
Я пытаюсь ввести apache Kafka в наш проект и изменить архитектуру проектов на...
Мы изучаем варианты оптимизации использования дискового пространства.При этом мы смотрели на...
Я только что обновился до весенней загрузки 2.1.3.RELEASE, и у меня не может быть более одного...
У меня есть эта конфигурация: @Configuration public class KafkaTopicConfig { private final...
В моем приложении у меня есть @kafkalistener и @jmslistener в классе diff, когда я запускаю...
Весенняя кафка у меня потребительское приложение. Приложение действует как проход, через который...
У меня есть два кластера Kafka, IP-адреса для которых я динамически выбираю из базы данных. Я...
Я использую пружинный каркас и кафку с 6 потребительскими нитками.После того, как 2 потока одной...
Документация по поддержке потоков Spring Kafka показывает что-то вроде: @Bean public...
Я настраиваю 10 тем Кафки в моем файле yaml, и мне нужно создать все темы при запуске приложения....
У меня очень простой вариант использования.У меня есть один потребитель Kafka, и я хочу переместить...
@ EmbeddedKafka выводит кучу ошибок при завершении работы.Есть ли способ предотвратить это?Трудно...
Я пытаюсь развернуть приложение весенней загрузки в Pivotal Cloud Foundry, чтобы использовать...
С помощью приложения Spring Cloud Stream Kafka, как мы можем гарантировать, что потоковый...
Я пытаюсь настроить apache kafka в весенней загрузке приложения.Я читаю эту документацию и выполняю...
Я новичок в Spring Cloud Dataflow и пытаюсь создать базовое потоковое приложение с источником HTTP,...
1) Я запускаю kafka на моей машине 2) Я запускаю свой весенний загрузочный сервер с конфигом: @Bean...
У меня есть требование получить метку времени (событие-время), когда сообщение было сгенерировано,...
Я установил простое приложение Spring Boot с Kafka Streams. Spring boot создает фабрику с помощью...