我有一个将数据发送到Kafka主题的代码。

public void sendMessage(String message, String key){
   if (isAsync) { // Send asynchronously
       producer.send(new ProducerRecord<String, String>(topic,key,message), new ProducerCallback(key, message));
   } else { // Send synchronously
       try {
           producer.send(new ProducerRecord(topic,key, message)).get();
       } catch (Exception e) {
           e.printStackTrace();
           // handle the exception
       }

   }

}
我使用下面的代码将数据传递给方法：

String Message ="Text message,Text message,Text message,Text message,Text message,Text message,Text message,Text message,Text message,Text message";
String Key = "0123456789";

for(int i =0; i < 10000; i++)
{
   publish.sendMessage(Message, Key);
}

由于消息和密钥是静态的，因此代码以低延迟（10k记录不到1秒）将数据发送到kafka，但如果使用动态密钥，性能会降低（10k记录几乎55秒）。代码将是

for(int i =0; i < 10000; i++)
{
   publish.sendMessage(Message, Key+i);
}