StackAsk is a community where developers ask questions, share answers and learn from each others real-world experience, so every solved problem helps the next person who runs into it.
<span>@Bean</span> public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<<span>String</span>, <span>String</span>>> kafkaListenerContainerFactory() { ConcurrentKafkaListenerContainerFactory<<span>String</span>, <span>String</span>> <span>factory</span> = <span>new</span> ConcurrentKafkaListenerContainerFactory<>(); <span>factory</span>.setConsumerFactory(consumerFactory()); <span>factory</span>.setConcurrency(<span>5</span>); ...... }
mails.parallelStream().forEach(sendMail); public void sendMail(mail) { try { send mail } catch(e) { lưu lại mail lỗi để retry sau } }
2.2K Point(s)
1.2K Point(s)
313 Point(s)
178 Point(s)
138 Point(s)
Input your email to receive reset password link, or if you remember your password, you can click