架构师提出flume-ng连接kafka时，通过zookeeper集群，zookeeper集群提供空闲的topic（或者空闲的kafka 我也不是很懂）给flume，这种怎么实现。我只知道已知topic名字和所在的服务器地址和端口进行单点连接，这种对于日志多的时候比较不安全。
架构师提出flume-ng连接kafka时，通过zookeeper集群，zookeeper集群提供空闲的topic（或者空闲的kafka 我也不是很懂）给flume，这种怎么实现。我只知道已知topic名字和所在的服务器地址和端口进行单点连接，这种对于日志多的时候比较不安全。