List of fetchOffset() Examples

Examples of fetchOffset()

co.cask.cdap.logging.kafka.KafkaConsumer.fetchOffset()
Fetch the earliest or latest available Kafka message offset. @param offset offset to fetch. @return Kafka message offset.

Examples of co.cask.cdap.logging.kafka.KafkaConsumer.fetchOffset()

          KafkaConsumer kafkaConsumer = new KafkaConsumer(seedBrokers, topic, partition, kafkaTailFetchTimeoutMs);
          try {
            Filter logFilter = new AndFilter(ImmutableList.of(LoggingContextHelper.createFilter(loggingContext),
                                                              filter));


            long latestOffset = kafkaConsumer.fetchOffset(KafkaConsumer.Offset.LATEST);
            long startOffset = fromOffset + 1;


            if (startOffset >= latestOffset) {
              // At end of events, nothing to return
              return;

View Full Code Here

Examples of co.cask.cdap.logging.kafka.KafkaConsumer.fetchOffset()

          KafkaConsumer kafkaConsumer = new KafkaConsumer(seedBrokers, topic, partition, kafkaTailFetchTimeoutMs);
          try {
            Filter logFilter = new AndFilter(ImmutableList.of(LoggingContextHelper.createFilter(loggingContext),
                                                              filter));


            long latestOffset = kafkaConsumer.fetchOffset(KafkaConsumer.Offset.LATEST);
            long earliestOffset = kafkaConsumer.fetchOffset(KafkaConsumer.Offset.EARLIEST);
            long stopOffset;
            long startOffset;


            if (fromOffset < 0)  {

View Full Code Here

Examples of co.cask.cdap.logging.kafka.KafkaConsumer.fetchOffset()

          try {
            Filter logFilter = new AndFilter(ImmutableList.of(LoggingContextHelper.createFilter(loggingContext),
                                                              filter));


            long latestOffset = kafkaConsumer.fetchOffset(KafkaConsumer.Offset.LATEST);
            long earliestOffset = kafkaConsumer.fetchOffset(KafkaConsumer.Offset.EARLIEST);
            long stopOffset;
            long startOffset;


            if (fromOffset < 0)  {
              stopOffset = latestOffset;

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.