我已经在google上搜索了一段时间,是否他们在loadrunner中有任何插件来测试Kafka集群,但什么也没有找到。我最近意识到,在像apache.kafka.clients这样的包的帮助下,我们可以通过java程序发送消息import org.apache.kafka.clients.producer.*;
{
public int end() t
(WindowStoreBuilder.java:40) at org.apache.kafka.streams.processor.internals.InternalTopologyBuilder(InternalTopologyBuilder.java:805)
at org.apache.kafka.streams.K