操作环境：
flink 1.12
kafka 0.10(3个broker)
通过flink-connector-kafka的api连接的kafka，想问下flink连kafka会根据topic的分区数动态确定source并行度么.
flink 连 kafka 的方式是什么？直连还是？
成为第一个点赞的人吧 
回复数量: 1
小小只鸟 的其他话题
分类下其他主题
- 现在问不了问题？
- 请问 hadoop 组件中的 hadoop 是安装在 /opt 下还是 /usr/local 下？
- HDFS 动态增加节点每次都要重启实验才行是为什么？
- MR 任务将数据写入 ORC 文件中，数据采用竖杠（|）进行分割，这个数据分割怎么设置？？希望大牛解答谢谢！！
- 为什么 hive 初始化 MySQL 出错？
- 为什么安装 datanode 出错？
- hadoop 为什么我没有在 public 下面找到 jdk 安装包？
- flink 的 standalone 模式部署后，Web 界面上，显示 taskmanager：0，total task slots：0，请问这个是怎么回事呢？
QQ群1：551936262
关注海汼部落技术社区
