DataWorks中Kafka Reader实现原理是什么？

Kafka Reader通过Kafka Java SDK读取Kafka中的数据，使用的日志服务Java SDK版本如下所示。org.apache.kafkakafka-clients2.0.0主要涉及的Kafka SDK调用方法如下，详情请参见Kafka官方文档：使用KafkaConsumer作为消息消费的客户端。 org.apache.kafka.clients.consumer.KafkaConsumer
根据unix时间戳查询Kafka点位offSet。 Map offsetsForTimes(Map timestampsToSearch)
定位到开始点位offSet。 public void seekToBeginning(Collection partitions)
定位到结束点位offSet。 public void seekToEnd(Collection partitions)
定位到指定点位offSet。 public void seek(TopicPartition partition,long offset)
客户端从服务端拉取poll数据。 public ConsumerRecords poll(final Duration timeout)说明 Kafka Reader消费数据使用了自动点位提交机制。
https://help.aliyun.com/document_detail/137745.html，此回答整理自钉群“DataWorks交流群(答疑@机器人)”