我正在使用命令行生产者和消费者对 Kafka 进行测试运行。
我在一个终端窗口中运行它
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic tag7
这在另一个
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic tag7 --zookeeper localhost:2181
但是我发送给消费者的数据需要 1 秒多的时间。我发送的数据是我输入到生产者的数据，所以基本上每隔几秒就会有 1 条消息。是否有任何我可以更改的配置选项，以便 Kafka 代理每秒期望很少的消息，从而使消息移动得更快？
我使用的是Zookeeper和Kafka的默认配置，所以配置不多。
先感谢您！