@Test public void getEndOffset_returnsEndOffset() { expectCreate(consumer); consumer.updateEndOffsets( singletonMap(new TopicPartition(TOPIC, PARTITION), END_OFFSET)); assertEquals(END_OFFSET, consumerManager.getEndOffset(TOPIC, PARTITION)); }
public long getEndOffset(String topic, int partition) { log.debug("End offset for topic {} and partition {}.", topic, partition); KafkaConsumerState<?, ?, ?, ?> consumer = getAdminConsumerInstance(); return consumer.getEndOffset(topic, partition); }
KafkaConsumerManager { public long getEndOffset(String topic, int partition) { log.debug("End offset for topic {} and partition {}.", topic, partition); KafkaConsumerState<?, ?, ?, ?> consumer = getAdminConsumerInstance(); return consumer.getEndOffset(topic, partition); } }
KafkaConsumerManager { public long getEndOffset(String topic, int partition) { log.debug("End offset for topic {} and partition {}.", topic, partition); KafkaConsumerState<?, ?, ?, ?> consumer = getAdminConsumerInstance(); return consumer.getEndOffset(topic, partition); } KafkaConsumerManager(final KafkaRestConfig config);   KafkaConsumerManager(KafkaRestConfig config, KafkaConsumerFactory consumerFactory); }
KafkaConsumerManager { public long getEndOffset(String topic, int partition) { log.debug("End offset for topic {} and partition {}.", topic, partition); KafkaConsumerState<?, ?, ?, ?> consumer = getAdminConsumerInstance(); return consumer.getEndOffset(topic, partition); } KafkaConsumerManager(final KafkaRestConfig config);   KafkaConsumerManager(KafkaRestConfig config, KafkaConsumerFactory consumerFactory); String createConsumer(String group, ConsumerInstanceConfig instanceConfig); void readRecords(
      final String group,
      final String instance,
      Class<? extends KafkaConsumerState<KafkaKeyT, KafkaValueT, ClientKeyT, ClientValueT>>
          consumerStateType,
      final long timeout,
      final long maxBytes,
      final ConsumerReadCallback<ClientKeyT, ClientValueT> callback
  ); Future commitOffsets(
      String group, String instance, final String async,
      final ConsumerOffsetCommitRequest offsetCommitRequest, final CommitCallback callback
  ); ConsumerCommittedResponse committed(
      String group,
      String instance,
      ConsumerCommittedRequest request
  ); long getBeginningOffset(String topic, int partition); long getEndOffset(String topic, int partition); Optional<Long> getOffsetForTime(
      String topic, int partition, Instant timestamp); void deleteConsumer(String group, String instance); void subscribe(String group, String instance, ConsumerSubscriptionRecord subscription); void unsubscribe(String group, String instance); ConsumerSubscriptionResponse subscription(String group, String instance); void seekToBeginning(String group, String instance, ConsumerSeekToRequest seekToRequest); void seekToEnd(String group, String instance, ConsumerSeekToRequest seekToRequest); void seekToOffset(
      String group,
      String instance,
      ConsumerSeekToOffsetRequest seekToOffsetRequest
  ); void assign(String group, String instance, ConsumerAssignmentRequest assignmentRequest); ConsumerAssignmentResponse assignment(String group, String instance); void shutdown(); }
KafkaConsumerManager { public long getEndOffset(String topic, int partition) { log.debug("End offset for topic {} and partition {}.", topic, partition); KafkaConsumerState<?, ?, ?, ?> consumer = getAdminConsumerInstance(); return consumer.getEndOffset(topic, partition); } KafkaConsumerManager(final KafkaRestConfig config);   KafkaConsumerManager(KafkaRestConfig config, KafkaConsumerFactory consumerFactory); String createConsumer(String group, ConsumerInstanceConfig instanceConfig); void readRecords(
      final String group,
      final String instance,
      Class<? extends KafkaConsumerState<KafkaKeyT, KafkaValueT, ClientKeyT, ClientValueT>>
          consumerStateType,
      final long timeout,
      final long maxBytes,
      final ConsumerReadCallback<ClientKeyT, ClientValueT> callback
  ); Future commitOffsets(
      String group, String instance, final String async,
      final ConsumerOffsetCommitRequest offsetCommitRequest, final CommitCallback callback
  ); ConsumerCommittedResponse committed(
      String group,
      String instance,
      ConsumerCommittedRequest request
  ); long getBeginningOffset(String topic, int partition); long getEndOffset(String topic, int partition); Optional<Long> getOffsetForTime(
      String topic, int partition, Instant timestamp); void deleteConsumer(String group, String instance); void subscribe(String group, String instance, ConsumerSubscriptionRecord subscription); void unsubscribe(String group, String instance); ConsumerSubscriptionResponse subscription(String group, String instance); void seekToBeginning(String group, String instance, ConsumerSeekToRequest seekToRequest); void seekToEnd(String group, String instance, ConsumerSeekToRequest seekToRequest); void seekToOffset(
      String group,
      String instance,
      ConsumerSeekToOffsetRequest seekToOffsetRequest
  ); void assign(String group, String instance, ConsumerAssignmentRequest assignmentRequest); ConsumerAssignmentResponse assignment(String group, String instance); void shutdown();  }