предположим, что я отправляю сообщения Kk асинхронно в Kafka, и по какой-то причине, скажем, я все еще жду подтверждения для всех сообщений 12k. Тогда, сколько потоков будет создано весенним загрузочным приложением, когда я жду всех подтверждений 12k?
Я просто отправляю фрагмент кода для краткости
@Service
@Scope("prototype")
public class HelloKafkaProducer {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
String topicName = "t_hello_world";
int i = 0;
int counter;
ListenableFuture<SendResult<String, String>> future = null;
public List<ListenableFuture<SendResult<String, String>>> sendMessage(String message) {
List<ListenableFuture<SendResult<String, String>>> cf = new ArrayList<ListenableFuture<SendResult<String, String>>>();
while (i < 12000) {
future = kafkaTemplate.send(topicName, message);
cf.add(future);
i++;
future.addCallback( ..... //callback code gioes here .omitted for brevity