admin管理员组

文章数量:1642239

1、kafka的send 默认发送方式应该是同步，而非异步

public ApacheKafkaClient(String kafkaServers, boolean sync) throws Exception {
    super(kafkaServers, sync);
}

查看父类VersionKafkaClient

2、kafka调用send方法有3种方式
//单条发送

public void send(String topic, String message) throws Exception {
    if (topic != null && message != null) {
        ProducerRecord<String, String> record = new ProducerRecord(topic, message);
        if (this.sync) {
            this.producer.send(record).get();
        } else {
            this.producer.send(record);
        }

    }
}

//批量发送

public void send(String topic, Collection<String> messages) throws Exception {
    Iterator var3 = messages.iterator();
    while(var3.hasNext()) {
        String message = (String)var3.next();

本文标签： 小结方法Kafkasend

版权声明：本文标题：kafkasend方法小结 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/xitong/1729333572a1196699.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。