OrcHome OrcHome
OrcHome个人中心.

张先森

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中:
组名要相同 就不会重复了。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中:
谢谢解答。还有我为什么发送一个数据消费者能接受到三条相同的数据呢?这是为什么啊
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中:
是的,close相当于关闭了这个通道。
3月前
张先森 kafka消费者客户端(0.10.0.1API) 发表评论:
辛苦解答,我这有一个问题:
kafka客户端发送消息producer.send(new ProducerRecord<String, String>(topic, key, value), new Callback() {},关闭生产者和不关闭会有什么影响吗?producer.close();因为我现在出现一个问题“Cannot send after the producer is closed. ”。这个是不是因为我发送的时候关闭了生产者接下来又发送消息导致的呢?
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中:
会,如果你代码中包含手动提交,就必须关掉自动提交,否则将会重复消息,也会丢消息。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中:
谢谢,还有一个问题,就是消费者设置<entry key="enable.auto.commit" value="false" />,这个配置手动和自动提交区别在那呢,如果配置手动提交如果没有提交的话会重复消费吗?


3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中:
是的,是通过这个来尝试重发的。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中:
非常感谢解答。如果使用KafkaProducer.send(record, callback),当消息发送失败,不是有一个消息重发的配置:retries。
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中:
不会重发 全部确认才会认为成功
3月前
张先森 kafka消费者客户端(0.10.0.1API) 发表评论:
有个问题想问问,期待解答kafka调用send()方法发送消息,配置的acks=all,如果所有机器都宕机的情况,这个时候如果重启后这个消息还会自动发送吗?或者说这个消息是已经丢失了?还有一种情况是如果有一台机器没有确认消息,这种情况也算是发送失败。那这个消息也算是丢失还是kafka会保存么?

3月前

半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 评论:
组名要相同 就不会重复了。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 评论:
谢谢解答。还有我为什么发送一个数据消费者能接受到三条相同的数据呢?这是为什么啊
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 评论:
是的,close相当于关闭了这个通道。
3月前
张先森 kafka消费者客户端(0.10.0.1API) 发表评论:
辛苦解答,我这有一个问题:
kafka客户端发送消息producer.send(new ProducerRecord<String, String>(topic, key, value), new Callback() {},关闭生产者和不关闭会有什么影响吗?producer.close();因为我现在出现一个问题“Cannot send after the producer is closed. ”。这个是不是因为我发送的时候关闭了生产者接下来又发送消息导致的呢?
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 评论:
会,如果你代码中包含手动提交,就必须关掉自动提交,否则将会重复消息,也会丢消息。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 评论:
谢谢,还有一个问题,就是消费者设置<entry key="enable.auto.commit" value="false" />,这个配置手动和自动提交区别在那呢,如果配置手动提交如果没有提交的话会重复消费吗?


3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 评论:
是的,是通过这个来尝试重发的。
3月前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 评论:
非常感谢解答。如果使用KafkaProducer.send(record, callback),当消息发送失败,不是有一个消息重发的配置:retries。
3月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 评论:
不会重发 全部确认才会认为成功
3月前
张先森 kafka消费者客户端(0.10.0.1API) 发表评论:
有个问题想问问,期待解答kafka调用send()方法发送消息,配置的acks=all,如果所有机器都宕机的情况,这个时候如果重启后这个消息还会自动发送吗?或者说这个消息是已经丢失了?还有一种情况是如果有一台机器没有确认消息,这种情况也算是发送失败。那这个消息也算是丢失还是kafka会保存么?

3月前