kafka-connect-hive sink插件实现了以ORC和Parquet两种方式向Hive表中写入数据。Connector定期从Kafka轮询数据并将其写入HDFS，来自每个Kafka主题的数据由提供的分区字段进行分区并划分为块，每个数据块都表示为一个HDFS文件，文件名由topic名称+分区编号+offset构成。如果配置中
每一个节点都有机会当簇首，如果已经当过簇首，则Gr集合不包括此节点。 此时，准备阶段完成。 此协议是为了解决多Sink,移动的Sink场景下的协议。 缺点：多次广播，耗费大量能量；增加无线交互的碰撞; 维护状态负担重。 实现
1 官网内容 2 看一张图一目了然 3 详细配置 source配置文件 #配置文件： a1.sources= r1 a1.sinks= k1 k2 a1.channels= c1 #负载平衡 a1.sinkgroups = g1 a1.sinkgroups.g1.sinks = k1 k2 a1.sinkgroups.g1.processor.type = failover a1.sin
