druid-kafka-ext-master.zip （48个子文件） 
druid-kafka-ext-master kafka-eight-ex 
pom.xml 3KB src test java io druid firehose kafka support KafkaIngestConsumer.java 5KB SimpleTwoPartitioner.java 492B LocalZookeeperAndKafka.java 776B MiddleLevelConsumerInLocal.java 5KB ProducerEx.java 1KB TestKafkaProducer.java 3KB TestZookeeperServer.java 2KB UTGlobal.java 583B TestKafkaServer.java 2KB ReflectFieldUtil.java 2KB SimplePartitioner.java 467B TestKafkaMessageSerializer.java 740B KafkaMessageSerializer.java 538B KafkaZKInfoTest.java 6KB MiddleLevelConsumer.java 5KB lowlevelapi test FullGc.java 1009B KafkaLowLevelApiTest.java 14KB main resources META-INF services io.druid.initialization.DruidModule 58B log4j.xml 2KB java com ebay pulsar druid firehose kafka KafkaEightDruidModule.java 1KB KafkaEightFirehoseFactory.java 7KB support SimpleConsumerController.java 18KB DefaultPartitionCoordinator.java 2KB ConsumerPartitionReader.java 14KB data KafkaZKData.java 33KB ConsumerId.java 3KB KafkaConsumerConfig.java 1KB RebalanceResult.java 2KB BasePartitionCoordinator.java 6KB exceptions KafkaPartitionReaderClosedException.java 632B KafkaPartitionReaderException.java 839B KafkaZKException.java 716B api PartitionReader.java 2KB AssignorContext.java 862B KafkaConsumer.java 2KB SimpleController.java 2KB PartitionCoordinatorStrategy.java 2KB ZKConnector.java 5KB util TopicCount.java 8KB JSON.java 1KB NameableThreadFactory.java 1KB LOG.java 1KB PropertiesUtils.java 1KB DefaultAssignorContext.java 1KB SimpleConsumerEx.java 20KB LICENSE.md 12KB README.md 264B资源评论
