KafkaUtil.sendMsg("yjxxt", "Hello Flink Kakfa" + i + "," + System.currentTimeMillis());
时间: 2024-04-15 11:08:03 浏览: 80
这是发送 Kafka 消息的代码,其中 "yjxxt" 是指 Kafka 的主题,"Hello Flink Kafka" + i + "," + System.currentTimeMillis() 是消息的内容,可以根据实际需求进行修改。你需要先引入 Kafka 的依赖,然后创建一个 Kafka 生产者实例,使用该实例发送消息即可。具体实现可以参考以下代码示例:
```
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
import java.util.Properties;
public class KafkaUtil {
private static KafkaProducer<String, String> producer = null;
static {
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
producer = new KafkaProducer<>(props);
}
public static void sendMsg(String topic, String msg) {
ProducerRecord<String, String> record = new ProducerRecord<>(topic, msg);
producer.send(record);
}
}
```
需要注意的是,这里使用了 Kafka 的默认配置,如需要进行配置修改可以在 Properties 中指定相应的配置项。
阅读全文