单个broker和集群broker的topic创建和发送消息的问题

来源:11-6 Kafka SSL客户端集成

乃好

2020-05-17

老师您好,

一开始我们的学习是单个节点的,

创建topic的时候要先创建一个AdminClient,其中指定了ip和端口,发送数据和消费数据都是要配置这个ip和端口的,这是很确定的一件事。


但是如果在集群的情况下,我使用AdminClient创建了一个topic,AdminClient中的配置是有好多个ip和端口的设置的,可能还有多个partitiion和副本集,那么这个时候,假设我把所有机器全部关了,再重新只开启一台,这个时候我的生产者中的配置也填写了这台机器的ip和端口,向刚刚创建的topic中发送消息,这样发送数据是不是有可能会报错呢?因为有可能这台机器存放的恰巧并不少leader节点而是follower节点,或者这台broker并不是controller,但是再一想,只开启一台机器的话,不就是类似与其他节点坏了,kafka会重新选举leader吗。。。


之所以问这个问题,是因为我单独开启了集群中的一个节点,然后向其发送消息,然后报错了



写回答

1回答

Allen

2020-05-17

有这个可能性, 所以在生产环境一般其实都是配置域名, 然后让域名转发给所有的kafka节点。 只不过这种方式牵涉的内容比较多, 等后期更新的时候我再更新上吧

0
0

Kafka多维度系统精讲,从入门到实战开发

系统讲解Kafka,实战结合,让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程