Flink Kafka Connector分析

文章目录 Flink Kafka Connector分析 1 FlinkKafkaConsumer 1.1 FlinkKafkaConsumerBase 1.2 AbstractPartitionDiscoverer 1.3 AbstractFetcher 1.4 KafkaConsumerThread 1.5 Handover 1.6 总结 2 FlinkKafkaProducer Flink
相关文章
相关标签/搜索