spring-kafka — все вопросы

1ответ
4 голоса
Как реализовать слушатель сообщений с сохранением состояния с помощью Spring Kafka?
Я хотел бы реализовать прослушиватель с отслеживанием состояния с использованием API Spring Kafka. Учитывая следующее: ConcurrentKafkaListenerContainerFactory с параллелизмом, установленным н
1ответ
4 голоса
Использование Spring Kafka JsonSerializer
Я пытаюсь следовать инструкциям здесь: http: //docs. spring.io/spring-kafka/docs/1.1.1.RELEASE/reference/htmlsingle/#_serialization_deserialization_and_message_conversion Чтобы настроить шаб
1ответ
4 голоса
Кафка перестает потреблять сообщения из новых назначенных разделов после перебалансировки
Я довольно новичок в kafka (также в английском ...), я столкнулся с этой проблемой и не могу найти какие-либо решения Google. Я использую Spring-Boot, поддержку Spring-Kafka, я установил kafka_2.
2ответа
4 голоса
Класс отсутствует в доверенных пакетах, хотя отображается в списке доверенных пакетов.
Я пытаюсь реализовать простую связь Kafka между двумя различными приложениями Spring Boot без каких-либо специальных настроек, в этом приложении есть только один kafkalistener Мой yml для потребител
1ответ
4 голоса
пружина Кафка теряет InstanceAlreadyExistsException исключение после установки параллелизма> 1
Я использую spring-kafka, все работает, если я не устанавливаю параллелизм ConcurrentKafkaListenerContainerFactory, когда я устанавливаю его на число больше 1, я получаю исключение:javax.management.In
2ответа
4 голоса
Синхронизация транзакций в Spring Kafka
Я хочу синхронизировать транзакцию kafka с транзакцией репозитория:После слияния ( https://github.com/spring-projects/spring-kafka/issues/373 ) и в соответствии с документом это возможно.Тем не менее
1ответ
4 голоса
Spring Kafka Всегда перебалансируется через 5 минут, даже если я остановлюсь у потребителя
есть трудоемкая операция (около 10 минут), но кафка избегает восстановления баланса через 5 минут, даже если я делаю паузу для потребителя.потребительский метод:это мой конфиг:ЖУРНАЛОВ
1ответ
4 голоса
Kafka потребительские исключения и смещения совершает
Я пытался сделать POC-работу для Spring Kafka.В частности, я хотел поэкспериментировать с лучшими практиками в отношении устранения ошибок при использовании сообщений в Kafka.Мне интересно, если кто-н
4ответа
4 голоса
Spring Kafka - Как сбросить смещение до последнего с идентификатором группы?
В настоящее время я использую Spring Integration Kafka для создания статистики в реальном времени.Тем не менее, имя группы заставляет Kafka искать все предыдущие значения, которые слушатель не читал.Я
3ответа
4 голоса
Spring Kafka: несколько прослушивателей для различных объектов в ApplicationContext
Могу ли я узнать у сообщества, каков наилучший способ прослушать несколько тем, каждая из которых содержит сообщение своего класса?Я играл с Spring Kafka последние пару дней.Мой мыслительный процесс д
1ответ
7 голосов
Тестирование @KafkaListener с использованием Spring Embedded Kafka
Я пытаюсь написать модульный тест для слушателя Kafka, который я разрабатываю с помощью Spring Boot 2.x. Будучи модульным тестом, я не хочу запускать полноценный сервер Kafka с экземпляром Zookeeper
2ответа
11 голосов
Производитель Kafka TimeoutException: Истекает 1 запись (и)
Я использую Kafka с Spring-boot: Класс продюсера Кафки : @Service public class MyKafkaProducer { @Autowired private KafkaTemplate<String, String> kafkaTemplate; private

Популярные теги

security × 330linux × 316macos × 2827 × 268performance × 244command-line × 241sql-server × 235joomla-3.x × 222java × 189c++ × 186windows × 180cisco × 168bash × 158c# × 142gmail × 139arduino-uno × 139javascript × 134ssh × 133seo × 132mysql × 132