我使用camel-through-java-dsl构建了一个kafka消费者：

from(endpoint).process(new Processor() {

    @Override
    public void process(Exchange exc) throws Exception {

        setMessageBeanInExchange(exc);
    }                       
}).bean(Service.class);

在类的main方法下，我只创建一个新对象，开始使用kafka的消息。在本地jvm中，它一直运行，甚至不提供thread.sleep（）。
在jmeter下测试同一个类时，它会立即退出并且不使用消息。需要帮助我如何保持它在jmeter中运行，直到我的所有消息都被用来监视时间和各种日志。