поэтому я реализовал простой клиент kafka, следуя книге, я знаю, как использовать его в main
методе, таком как:
while(true){
records = consumer.poll(100);
//process records in for loop
consumer.commit();
}
, но я не знаю, как запустить while(true)
в войне.приложение, или как использовать мой клиент в spring-kafka?