Вопросы с тегом весна-кафка

4 голосов

3 ответов

Невозможно отправлять сообщения на мертвую букву topi c от потребителя в Kafka

Abhijith Gururaj / 07 августа 2020

0 голосов

0 ответов

Модульный тест для @KafkaListener - исключение нулевого указателя

Swapnil / 07 августа 2020

0 голосов

1 ответ

Spring Cloud Stream (Kafka) параметризует указанный канал ошибки {destination}. {Group} .errors

user2095692 / 05 августа 2020

0 голосов

1 ответ

Нужна помощь | UnitTest | Пользовательский ConcurrentKafkaListenerContainerFactory с настраиваемой записью FilterStrategy

Pratap S / 04 августа 2020

0 голосов

2 ответов

Лучший способ обработки ошибок в Kafka Consumer

Mangla / 03 августа 2020

1 голос

1 ответ

Приложение Kafka для нескольких потребителей

sam / 03 августа 2020

0 голосов

1 ответ

запускать потребителя kafka после завершения события

Brajesh kothari / 02 августа 2020

0 голосов

1 ответ

Заголовок имени группы потребителей для сообщения DLT spring-cloud-stream kafka

ppysz / 13 июля 2020

0 голосов

1 ответ

Как сообщить потребителю spring-kafka о прекращении потребления во время выполнения?

Clément V / 13 июля 2020

0 голосов

1 ответ

Могут ли сообщения быть потеряны на стороне производителя kafka во время развертывания?

Swapnil Bagadia / 10 июля 2020

0 голосов

1 ответ

Можем ли мы добавить свойство Dynami c в @KafkaListener (propertyes = {max.pool.size.ms: тернарный оператор

sherybedrock / 10 июля 2020

0 голосов

1 ответ

Почему Kafka Consumer повторно обработал все записи за последние 2 месяца?

harshal pande / 10 июля 2020

0 голосов

1 ответ

Почему производитель asyn c создает сообщения с linger.ms и batch.size, для которых установлено большое значение, а для autoFlu sh установлено значение false?

Raj / 09 июля 2020

0 голосов

1 ответ

Функция @KafkaListener вызвана, но получает пустой список

Augusto / 09 июля 2020

0 голосов

1 ответ

Есть ли в кафке какой-либо механизм, который отклонит сообщение, если в сообщении есть ключ, но это уже сообщение в кафке с тем же ключом?

Bravo / 09 июля 2020

0 голосов

1 ответ

Почему производитель asyn c не ждет заполнения linger.ms или batch.size, когда я устанавливаю для них настраиваемое значение с autoFlu sh, равным false?

Raj / 09 июля 2020

0 голосов

1 ответ

Несколько StreamListeners к одному Topi c с Spring Cloud Stream, подключенным к Kafka

Mykhailo Yablon / 19 июня 2020

0 голосов

0 ответов

Где находится труба ec2?

sc cc / 19 июня 2020

0 голосов

1 ответ

Какая конфигурация SSL необходима для Spring Kafka для подключения к Kafka?

user4944342 / 19 июня 2020

0 голосов

1 ответ

Kafka - Сброс смещения для раздела не работает

Martin Linha / 19 июня 2020

0 голосов

1 ответ

Повторяющиеся потребительские метрики, если для параллелизма установлено более 1

Raj / 18 июня 2020

0 голосов

1 ответ

ReplyingKafkaTemplate с KafkaTransactionManager вызывает исключение

Jorge Avelar / 18 июня 2020

0 голосов

1 ответ

Сообщения не отправлены в тему DLQ

Himanshu Parwani / 17 июня 2020

1 голос

0 ответов

mongoDB вставляется дважды при вызове в разных потоках

Himanshu Parwani / 17 июня 2020

0 голосов

1 ответ

Кафка: в чем смысл использования «cknowledgement.nack », если я могу просто« не подтвердить.acknowledge »

Jim C / 16 июня 2020