帮助为jmeter，kafka编写脚本逻辑[关闭]

“帮助”是什么意思？有了这样的要求，你正在上班或上班

他们在这里回答问题，这意味着你必须先尝试自己做某事，如果由于某种原因突然不起作用，然后问为什么它不起作用：如何提​​出一个好问题？

作为一个例外：

1. 向 Kafka 发送消息的示例代码

   import org.apache.kafka.clients.producer.KafkaProducer
   import org.apache.kafka.clients.producer.ProducerRecord
   
   def props = new Properties()
   props.put("bootstrap.servers", "localhost:29092")
   props.put("acks", "all")
   props.put("retries", 0)
   props.put("batch.size", 16384)
   props.put("linger.ms", 1)
   props.put("buffer.memory", 33554432)
   props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
   props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")
   
   
   def producer = new KafkaProducer<>(props)
   
   producer.send(new ProducerRecord<>('foo', '{"order": "' + UUID.randomUUID() + '", "value1": 5, "value2": 3}'))
   
   producer.close()
   

2. 从 Kafka 读取消息并写入文件的示例代码 import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.clients.consumer.KafkaConsumer

   def props = new Properties()
   props.put("bootstrap.servers", "localhost:29092")
   props.put("acks", "all")
   props.put("retries", 0)
   props.put("batch.size", 16384)
   props.put("linger.ms", 1)
   props.put("buffer.memory", 33554432)
   props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
   props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
   props.put("group.id", "foo")
   
   
   def consumer = new KafkaConsumer<String, String>(props)
   consumer.subscribe(Arrays.asList('foo'))
   ConsumerRecord record = consumer.poll(1000).first()
   
   def value = new JsonSlurper().parseText(record.value())
   
   def uuid = value.order
   def value1 = value.value1
   def value2 = value.value2
   
   def sum = value1 + value2
   
   new File('your-file.txt') << 'order_' << uuid << ' SUMM ' << sum
   
   consumer.close()
   

材料：

• 使用 Kafka java 客户端发送和接收 JSON 对象
• 卡夫卡Java客户端
• 如何使用 JMeter 进行 Kafka 测试