Вопросы с тегом 'spring-kafka'

Количество результатов: 201

0 голосов
1 ответ
возможно иметь оба слушатель и контейнер обработчиков ошибок

Я строй общей весенней Кафка конфигурации для команд, чтобы использовать в своих проектах. Я хотел бы, чтобы определить общий пользовательский обработчик ошибок на ур...

3 голоса
0 ответов
Reload SSL контекст используется Spring Кафки во время выполнения

Что такое рекомендуемый способ сделать Spring Кафка контекста перезарядки SSL? У меня есть требование, чтобы вставить новые сертификаты в хранилище доверенного, что м...

0 голосов
1 ответ
Dynamic Spring Кафка Слушатель

Я использую пружинный Кафка с SPEL и пытаюсь слушать разные темы на основе значения, присутствующий в одном из файла свойств. @KafkaListener (темы = "# {kafkaTopics.g...

0 голосов
1 ответ
с использованием HTTP: inboundgateway с Кафкой весенней интеграции

Я новичок в весенней интеграцию Кафки и поток данных весны облака. так что моя проблема в том, что я пытаюсь построить HTTP POST с запросом/обмена ответ с помощью HTTP...

2 голоса
1 ответ
Настройка Spring Кафку использовать DeadLetterPublishingRecoverer

Я использую Spring бутс 2.1.3 и пытаюсь настроить Spring SeekToCurrentErrorHandler с а DeadLetterPublishingRecoverer для отправки записей об ошибках в другую тему. Нов...

1 голос
1 ответ
Потребляя сообщения от Apache Kafka в Avro формате

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

0 голосов
1 ответ
Обработка ошибки десериализации JSON с Spring KafkaListener

Я использую Spring KafkaListener потреблять некоторые сообщения из темы Кафки. Глядя на журналах, я заметил ошибку при попытке deserialise сообщения JSON в боб. Исклю...

0 голосов
1 ответ
путь проблема внутри докер доверенных сертификатов с пружинным ботинке и Кафки

у меня есть технические проблемы, пытаясь решить при развертывании моего приложения весны загрузки приложения с Docker контейнером. org.apache.kafka.common.KafkaEx...

0 голосов
1 ответ
Сообщение под Кафкой темы также называется журналом?

Сообщение под Кафкой темы также называется журналом? войти разделы = Тема раздела сообщений? # The default number of log partitions per topic. More partitions allow ...

1 голос
0 ответов
Кафка потоки застряли на потребление вскоре после запуска приложения

Я использую как Кафку и Кафку Streams в моем приложении Spring. В то время как регулярные Кафки связь, такие как отправка/прием/с тем, работает отлично, Кафка Streams ...

0 голосов
1 ответ
Пружина Кафка фильтр не фильтровать записи потребителей

Я пытаюсь фильтровать сообщения ConsumerRecord перед употреблением, на основе содержания на одном из полей в ConsumerRecord. Пример записи потребитель перед применен...

0 голосов
2 ответа
Как грациозно Turn Off Запуск Кафка Потребителя

У меня есть необходимость включить Кафка потребитель включения/выключения на основе некоторых из баз данных недвижимости. Как это может быть достигнуто. один способ,...

0 голосов
0 ответов
Вызов функций на основе результата другой функции (Кафка)

У меня есть функции А, В и С Когда я вызываю функцию A(), будет послана Кафки Notif и когда Notif обрабатывается и посылается ответ, мне нужно функцию вызова B() и сно...

0 голосов
0 ответов
Интеграция Spring Кафка с встроенными Кафками

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

0 голосов
1 ответ
Spring Кафка не возвращает нуль для Tombstone записей во время пакетной обработки

Кажется, что весна весна Кафка игнорирование @Payload(required = false) аннотации во время пакетной обработки. По-крайней мере, вместо того, чтобы null за Tombstone Я ...

4 голоса
1 ответ
Запись на две темы Кафки в одной транзакции с использованием Spring Кафку

Я пытаюсь работать, если есть способ использования функции транзакции Кафки писать двум темы в рамках одной транзакции. Я знаю, типичный сценарий использования транза...

0 голосов
1 ответ
Весна Облако StreamListener @output KStream SerDes не кажется работе

У меня есть поток Listener как @StreamListener(target = "requesti") @SendTo("responseo") public KStream<UUID,Account> process(KStream<UUID, Account> event...

0 голосов
1 ответ
рессора Облако ручейки потребитель конфигурации не работает

Я использую весной загрузки 2.0.3-RELEASE версии. Это мой конфигурационный файл. Когда я начинаю потребителя, то его начало с по умолчанию configuration.They не переоп...

0 голосов
1 ответ
если установить spring.kafka.listener.ack-режим = время, будет повторять работу? или повторить работу в заданном режиме подтверждени?

Spring Кафка - Как Retry с @KafkaListener spring-kafka SeekToCurrentErrorHandler если установлено spring.kafka.listener.ack-mode=time, Будет повторять работу? или пов...

0 голосов
1 ответ
весна облако потока - группа потребителей связана

Мой потребитель обязан анонимная группа потребителей, а не группы потребителей я указал. spring: cloud: stream: kafka: binder: brokers: ...

3 голоса
2 ответа
Весна Кафка интеграция тесты Ошибка при записи в файл highwatermark

Я пишу интеграционный тест с использованием пружинного кака-2.2.0 в приложении загрузки родниковой, я почти удался всем-таки мой случай возвращение теста правда, но вс...

0 голосов
0 ответов
Кафка Java потребитель не потребляет сообщения от определенного раздела

Я создал тему с 5 раздела с 3 репликацией factor.I имеет два хода потребителя приложений, и принадлежит к разным группам потребителей. У меня есть один производитель, ...

0 голосов
1 ответ
Как пройти мимо undeserializable сообщений в Spring Кафку 1.3 с Avro

Я не могу обновить до весны 5, так что я застрял с пружинными Кафками 1.3 и ее ограниченной обработкой ошибок. Таким образом, у меня нет доступа к ConsumerAwareErrorHa...

1 голос
1 ответ
Конфигурация Spring Загрузочный + Кафка + Kerberos

Я использую Spring бутс 1.5.6.RELEASE для подключения к Кафке 0.11 с помощью проверки подлинности Kerberos. Эти зависимости я использую для Кафки: <depende...

0 голосов
1 ответ
Spring Integration Кафка адаптер исходящий канал

У меня есть объект модели, который заполняется после нескольких преобразований и синтаксического анализа. Теперь мне нужно отправить атрибут сообщения в модели Кафка с...

1 голос
2 ответа
весна Кафка тест интеграции слушатель не работает

Я пытаюсь интеграционное тестирование с использованием spring-boot и весной встроенный Кафку. Я в состоянии произвести сообщение для весны встроенного сервера Кафки, н...

1 голос
1 ответ
Как различать ошибки сбоя соединения с базой данных против других исключений в DataAccessException в Spring Data JPA

Мне нужно определить исключения сбоя соединения базы данных против других исключений и обрабатывать соответствующим образом внутри моего Кафка обработчика ошибок слуша...

0 голосов
1 ответ
Что происходит с временной меткой сообщения в потоке, когда он переходит в другой поток?

Я приложение, в котором я обрабатывать поток и конвертировать его в другой. Вот пример: public void run(final String... args) { final Serde<Event> eventSerd...

0 голосов
0 ответов
Deserialize JSON для общего типа

У меня есть общий класс десериализовать из JSON. Как настроить JsonDeserializer в Котлин? org.springframework.kafka.support.serializer.JsonDeserializer ... ErrorHan...

1 голос
2 ответа
Весна-Кафка: Перебалансирование происходит при использовании потребительских пауз/возобновлении, который не должна в соответствии с документации

Весна-Кафка: В то время как приостановка/возобновление потребителя, используя метод приостановки/возобновления в соответствии с документацией, восстановить равновесие ...

1 голос
1 ответ
весна Кафка тестирование интеграции со встроенным Кафки

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

0 голосов
0 ответов
Кафка Потребитель покинул группу потребителей

Я столкнулся некоторые проблемы с использованием Кафки. Любая помощь высоко ценится! У меня Zookeeper и KAFKA группе 3 узлов, каждый в DOCKER рой. Конфигурация брокера...

0 голосов
1 ответ
Кафка: Как повторно потреблять ип покончил/не подтвержденное сообщение

Мы используем ручную фиксацию стратегии. Мы настроили боб, обязывающее все успешно потребляются сообщения. Мы пытаемся, чтобы добавить логику, чтобы повторно потребить...

0 голосов
1 ответ
Конфигурация карты для производителя Кафки в свойствах файла не удается

Я пытаюсь добавить конфигурацию производителя к моему проекту, с использованием Spring Integration и Кафку под ним. Так как я не нашел где-нибудь, чтобы положить его,...

1 голос
1 ответ
Весна Кафка MessageListenerContainer

Я вижу пружинную Кафка код и у меня есть некоторые сомнения: Если мы используем 1 @kafkaListener 2 темы, то весна Кафка создает один MessageListenerContainer. И есл...

0 голосов
1 ответ
весна Кафка Неоднозначные методы типа полезной нагрузки

Я стараюсь потреблять два разных типа полезной нагрузки от Кафки, используя тему spring-kafka-2.2.0 а также spring-boot-2.1.0 но, к сожалению, не повезло до сих пор не...

0 голосов
0 ответов
Удаление Кафке журналов, используя время удерживания

Я работаю на платформе окон, инструмент, в котором я буду выдавать сообщения Кафки из приложения загрузки яровой очень часто (функция будет непрерывно производит сообщ...

0 голосов
1 ответ
весна Кафка ConsumerFactory фасоль не найден

Я пытаюсь установить потребитель Кафки, используя spring-kaka-2.2.0 а также spring-boot-2.1.0 но у меня странный вопрос о том, ConsumerFactory боб не найден, но до сих...

0 голосов
1 ответ
Как повторно отправить (прочитать) старый Кафка сообщение от заданной темы и раздела в конкретном скомпенсировано с помощью пружинного Кафки?

Учитывая название темы, номер раздела и смещение, как я могу читать только одну запись от темы? В моем приложении на основе SPRNG загрузки я использую Кафку для импор...

3 голоса
1 ответ
Весна Кафка JsonDesirialization MessageConversionException не удалось разрешить имя класса класса не найден

У меня есть две услуги, которые должны общаться с помощью Kafka. Давайте назовем первый WriteService службы и второй QueryService службы. На стороне WriteService, у м...

0 голосов
1 ответ
Кафка руководство признать до весны загрузки выключения

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

-1 голос
1 ответ
Отличается от Кафки темы, весна-облако-поток канала и весна-облако потока назначения

Извините меня! У меня те же вопросы из моего teammates.They спросили меня, что это другая точка между Kafka темой, весной облаком потоком каналом и Spring Облаком пото...

0 голосов
0 ответов
Слушатель отправки запроса о выходе из группы Кафки

Мы используем Кафка весной. Я слушаю на несколько тем в моем потребительскому приложения (одного сервера, одновременно). Я не знаю, почему только один из слушателя пос...

0 голосов
0 ответов
Слушатель прекращает прием сообщений

В нашем весеннем приложении (весна-загрузки-стартер-веб-версии 2.1.2, и весенне-Кафка версии 2.2.X) у нас есть два слушателя: @Component public class Subscriber { ...

0 голосов
0 ответов
Как использовать несколько потребителей в ReplyingKafkaTemplate?

Я использую ReplyingKafkaTemplate. Класс DefaultKafkaConsumerFactory использовать один потребитель для ответа темы. Как использовать несколько потребителей для ответа ...

0 голосов
1 ответ
Получить название темы, раздела и смещение в случае обработчиков ошибок контейнеров

Я получаю исключение десериализации данных, потребляя от Кафки темы. Я хочу, чтобы установить смещение текущего +1. У меня есть обработчик ошибок на уровне контейнера,...

0 голосов
1 ответ
Продлить Kerberos билет с Spring Кафки

Мы внедрили в нашей Kerberos Кафка кластера recently.Clients нужно использовать SASL_SSL для общения с этим cluster.As мы используем пружинный Кафку в наших проектах, ...

0 голосов
1 ответ
Весна Облако поток: Правильное обращение за StreamListener, когда это занимает много времени, чтобы обработать сообщение

Когда StreamListener занимает длительное время (дольше max.poll.interval.ms), Чтобы обработать сообщение, таким образом, что конкретный потребитель занимает и другие н...

1 голос
1 ответ
Spring Кафка @KafkaListener - Retry отправки сообщений неисправных и вручную совершить смещение

Я использую @KafkaListener для потребляющих от темы Кафки, у меня есть логика приложения для обработки каждой записи по нескольким потребителям в разных группах потреб...

0 голосов
0 ответов
Зависимость autowired правильно в конструкторе становится нулевым позже автоматически тот же объект службы с KafkaListener

@EnableKafka @Configuration public class KafkaConfiguration { @Bean public ConsumerFactory<String, String> consumerFactory() { //configurations return new...

1 2 3 4 right