单个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节点。 只不过这种方式牵涉的内容比较多, 等后期更新的时候我再更新上吧
00
相似问题