上传者: 38504417
|
上传时间: 2022-03-15 10:12:07
|
文件大小: 35KB
|
文件类型: -
我就废话不多说了,直接 上代码吧!
import kafka.api.PartitionOffsetRequestInfo;
import kafka.common.TopicAndPartition;
import kafka.javaapi.OffsetResponse;
import kafka.javaapi.PartitionMetadata;
import kafka.javaapi.TopicMetadata;
import kafka.javaapi.TopicMetadataRequest;
import kafka.javaapi.consumer.SimpleConsu