void commitSync();


void commitSync(Map<TopicPartition, OffsetAndMetadata> offsets);


long position(TopicPartition partition);


OffsetAndMetadata committed(TopicPartition partition);

List<PartitionInfo> partitionsFor(String topic);

Map<String, List<PartitionInfo>> listTopics();

Map<TopicPartition, OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition, Long> timestampsToSearch);

Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions);

Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions);

    /**

    /**
     * Get the offset of the <i>next record</i> that will be fetched (if a record with that offset exists).
     * This method may issue a remote call to the server if there is no current position for the given partition.
     * <p>
     * This call will block until either the position could be determined or an unrecoverable error is
     * encountered (in which case it is thrown to the caller).
     *
     * @param partition The partition to get the position for
+    * @param timeout   The maximum duration of the method
     *
     * @return The current position of the consumer (that is, the offset of the next record to be fetched)
     * @throws IllegalArgumentException if the provided TopicPartition is not assigned to this consumer
     * @throws org.apache.kafka.clients.consumer.InvalidOffsetException if no offset is currently defined for
     *             the partition
     * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this
     * Get the offset of the <i>next record</i> that will be fetched  function is called(if a record with that offset exists).
     * @throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted before or while This method may issue a remote call to the server if there is no current position for the given partition.
     * <p>
     * This call will block until either thisthe functionposition iscould called
+be determined or an * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}unrecoverable error is
     * encountered (in which case it is thrown to the caller).
     *
     * @throws org.apache.kafka.common.errors.AuthenticationException if authentication fails. See@param partition The partition to get the exceptionposition for
+ more details
  * @param timeout * @throws org.apache.kafka.common.errors.AuthorizationException if not authorized to the topic or to the The maximum duration of the method
     *
     * @return The current position of the consumer (that is, configuredthe groupId.offset Seeof the exceptionnext record forto morebe detailsfetched)
     * @throws org.apache.kafka.common.KafkaException for any other unrecoverable errors
     */
+   long position(TopicPartition partition, Duration timeout);

 *    /**
     * Get the last thiscommitted offset functionfor isthe called
given partition (whether the commit *happened @throws org.apache.kafka.common.errors.AuthenticationException if authentication fails. See the exception for more details
     * @throws org.apache.kafka.common.errors.AuthorizationException if not authorized to the topic or to theby this process or
     * another). This offset will be used as the position for the consumer in the event of a failure.
     * <p>
     * This call will block to do configured groupId. Seea remote call to get the exception for more detailslatest committed offsets from the server.
     * @throws org.apache.kafka.common.KafkaException for any other unrecoverable errors
     * @param partition The partition to check
+    * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}@param timeout   The maximum duration of the method
     */
     OffsetAndMetadata* @return The last committed(TopicPartition partition,offset finaland Duration timeout)'

	/**
     * Commit the specified offsets for the specified list of topics and partitions.
     * <p>metadata or null if there was no prior commit
     * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this
     * This commits offsets to Kafka. The offsets committed using this API will befunction usedis oncalled
 the first fetch after every
*     * rebalance and also on startup. As such, if you need to store offsets in anything other than Kafka, this API@throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted before or while
     * should not be used. The committed offset should be the next message yourthis applicationfunction willis consume,called
     * i@throws org.e. lastProcessedMessageOffset + 1.
     * <p>apache.kafka.common.errors.AuthenticationException if authentication fails. See the exception for more details
     * This is a synchronous commits and will block until either the commit succeeds or an unrecoverable error is
@throws org.apache.kafka.common.errors.AuthorizationException if not authorized to the topic or to the
     *       * encountered (in which case it isconfigured throwngroupId. toSee the caller).exception for more details
     * <p>
 @throws org.apache.kafka.common.KafkaException for any other unrecoverable errors
+    * Note that asynchronous offset commits sent previously with@throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@link #commitAsync(OffsetCommitCallback)@code timeout}
     */
 (or similar) are guaranteedOffsetAndMetadata to have their callbacks invoked prior to completion of this methodcommitted(TopicPartition partition, final Duration timeout)'

	/**
     * Commit the specified offsets for the specified list of topics and partitions.
     * <p>
     * @paramThis commits offsets to AKafka. mapThe of offsets bycommitted partitionusing withthis associatedAPI metadata
+will be used on *the @paramfirst timeoutfetch after Maximumevery
 duration to block
  * rebalance and *
also on startup. As such, *if @throws org.apache.kafka.clients.consumer.CommitFailedException if the commit failed and cannot be retried.you need to store offsets in anything other than Kafka, this API
     * should not be used. The committed offset should be the next message Thisyour canapplication onlywill occurconsume,
 if you are using automatic group management with {@link #subscribe(Collection)},* i.e. lastProcessedMessageOffset + 1.
     * <p>
     * This is a synchronous commits and orwill ifblock thereuntil iseither anthe activecommit groupsucceeds withor thean sameunrecoverable groupIderror which is using group management.
     * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()}encountered (in which case it is calledthrown beforeto or while thisthe caller).
     * <p>
     * Note that asynchronous offset commits sent functionpreviously is calledwith the {@link #commitAsync(OffsetCommitCallback)}
     * @throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted before or while (or similar) are guaranteed to have their callbacks invoked prior to completion of this method.
     *
     * @param offsets  A map of offsets by thispartition functionwith isassociated calledmetadata
+.    * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}@param timeout  Maximum duration to block
     *
      * @throws org.apache.kafka.commonclients.errorsconsumer.AuthenticationExceptionCommitFailedException if authenticationthe fails.commit Seefailed theand exceptioncannot for more detailsbe retried.
     * @throws org.apache.kafka.common.errors.AuthorizationException if not authorized to the topic or to the
  This can only *occur if you are using automatic group management with     configured groupId. See the exception for more details
{@link #subscribe(Collection)},
     *           * @throws java.lang.IllegalArgumentExceptionor if there is an active group with the committedsame groupId offsetwhich is negative using group management.
     * @throws org.apache.kafka.common.KafkaExceptionerrors.WakeupException forif any other unrecoverable errors (e.g. if offset metadata{@link #wakeup()} is called before or while this
     *             function is too large orcalled
     * @throws org.apache.kafka.common.errors.InterruptException if the topic does not exist).
     */
    void commitSync(final Map<TopicPartition, OffsetAndMetadata> offsets, final Duration timeout);