У меня есть получатель, имеющий несколько обработчиков, и когда у потребителя есть прослушиватель Kafka, который делегирует вызов определенному обработчику, а обработчик выполняет и отправляет назад какой-то теме Kafka Producer.Но слушатель Kafka обрабатывает запрос в MultiThreading с помощью taskExecuter, KafkaListener -> DataProcessor -> Handler (Object) -> HandlerExecutor (с обработчиком объекта) -> TaskExecutor.submit (handlerExecutor).
, но иногдазапрос обрабатывается, а иногда нет, и поток теряется.и когда я снова запускаю этого потребителя, снова обрабатывается оставшийся запрос.Я не понимаю, это проблема с темой или проблема с Kafka.