绽放

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 绽放kafka消费者Java客户端 中 :

    有一次全部提交的,有一次一次提交的。

    6年前
  • 绽放kafka消费者Java客户端 发表评论:

    大神,若是手动提交offset,如果consumer一次性pull了100条消息出来,那么consumer.commitSync()这个方法一次性提交的是多少条消息的offset呢?

    6年前
  • 半兽人 回复 绽放kafka producer代码发送自定义消息类型 中 :

    没看出来差异,我给你看下我们的。

    /*
    从[生产者连接池]获取一条通道,然后发送[message]到broker集群

    @param topicName 主题名称
    @param message 消息
    @param <T> 消息类型
    */
    public <T> void sendMessage(String topicName, T message) throws Exception {
    // 连接
    Producer producer = null;

    // 阻塞调用消息发送
    try {
    producer = producerConnPool.getProducerConn();
    producer.send(new ProducerRecord<String, T>(topicName, message)).get();
    } catch (InterruptedException e) {
    logger.debug("send a message InterruptedException:", e);
    throw e;
    } catch (ExecutionException e) {
    logger.debug("send a message ExecutionException:", e);
    throw e;
    } catch (Exception e) {
    logger.error("fetch a producer connection Exception:", e);
    } finally {
    // 释放连接
    producerConnPool.releaseConn(producer);
    }
    }

    6年前
  • 半兽人 回复 绽放kafka producer代码发送自定义消息类型 中 :

    稍等,我在忙。

    6年前
  • 绽放kafka producer代码发送自定义消息类型 发表评论:

    我尝试了多遍,无意中发现了是producer.close()的关系,代码1中还有这一句没有加上去。

    6年前