Class Hierarchy
- java.lang.Object
- org.apache.gobblin.kafka.client.AbstractBaseKafkaConsumerClient (implements org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient)
- org.apache.gobblin.source.extractor.extract.AbstractSource<S,D> (implements org.apache.gobblin.source.Source<S,D>)
- org.apache.gobblin.source.extractor.extract.EventBasedSource<S,D>
- org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord (implements org.apache.gobblin.kafka.client.KafkaConsumerRecord)
- org.apache.gobblin.publisher.DataPublisher (implements org.apache.gobblin.capability.CapabilityAware, java.io.Closeable)
- org.apache.gobblin.publisher.SingleTaskDataPublisher
- org.wikimedia.gobblin.copy.Kafka1ConsumerClient.Factory (implements org.apache.gobblin.kafka.client.GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory)
Copyright © 2021. All rights reserved.