/**
 * Fetch data for the topics or partitions specified using one of the subscribe/assign APIs. It is an error to not have
 * subscribed to any topics or partitions before polling for data.
 * <p>
 * On each poll, consumer will try to use the last consumed offset as the starting offset and fetch sequentially. The last
 * consumed offset can be manually set through {@link #seek(TopicPartition, long)} or automatically set as the last committed
 * offset for the subscribed list of partitions
 *
 *
 * @param timeout The maximum time to block and poll for metadata updates or data.
 *
 * @return map of topic to records since the last fetch for the subscribed list of topics and partitions
 *
 * @throws org.apache.kafka.clients.consumer.InvalidOffsetException if the offset for a partition or set of
 *             partitions is undefined or out of range and no offset reset policy has been configured
 * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this
 *             function is called
 * @throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted before or while
 *             this function is called

/**
 * Block until we have an assignment (and fetch offsets, etc.).
 * <p>
 * It is an error to not have subscribed to any topics or partitions before polling for data.
 * <p>
 * Throws a {@link ClientTimeoutException} if the {@code maxBlockTime} expires before the operation completes, but it
 * is safe to try again.
 *
 * @param maxBlockTime The maximum time to block and poll for metadata updates
 *
 * @throws org.apache.kafka.common.errors.ClientTimeoutExceptionAuthenticationException if theauthentication metadatafails. updateSee doesn'tthe completeexception withinfor themore maxBlockTimedetails
 * @throws org.apache.kafka.common.errors.WakeupExceptionAuthorizationException if {@link #wakeup()} is called concurrently with this functioncaller lacks Read access to any of the subscribed
 * @throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted concurrently with this function
 * topics or to the configured groupId. See the exception for more details
 * @throws org.apache.kafka.clientscommon.consumer.InvalidOffsetExceptionKafkaException iffor theany offsetother forunrecoverable a partition or set oferrors (e.g. invalid groupId or
 *             partitionssession istimeout, undefinederrors ordeserializing out of range and no offset reset policy has been configuredkey/value pairs, or any new error cases in future versions)
 * @throws orgjava.apache.kafka.common.errors.AuthenticationExceptionlang.IllegalArgumentException if authentication fails. See the exceptiontimeout forvalue moreis detailsnegative
 * @throws orgjava.apache.kafka.common.errors.AuthorizationExceptionlang.IllegalStateException if callerthe consumer lacksis Readnot accesssubscribed to any topics or ofmanually theassigned subscribedany
 *             topicspartitions orto toconsume the configured groupId. See the exception for more detailsfrom
 */
public ConsumerRecords<K, V> poll(final Duration timeout)

/**
 * @throws org.apache.kafka.common.KafkaException for any other unrecoverable errors (e.g. invalid groupId or
 *             session timeout, or any new error cases in future versions)
 * @throws java.lang.IllegalArgumentException if the timeout value is negative
 * @throws java.lang.IllegalStateException if the consumer is not subscribed to any topics or manually assigned any
 *             partitions to consume from
 */
public void awaitAssignmentMetadata(final Duration maxBlockTime);
 
 
/**
 * Fetch data for the topics or partitions specified using one of the subscribe/assign APIs. It is an error to not have
 * subscribed to any topics or partitions before polling for data.
 * <p>
 * On each poll, consumer will try to use the last consumed offset as the starting offset and fetch sequentially. The last
 * consumed offset can be manually set through {@link #seek(TopicPartition, long)} or automatically set as the last committed
 * offset for the subscribed list of partitions
 *
 *
 * @param maxBlockTime The maximum time to block and poll for metadata updates or data.
 *
 * @return map of topic to records since the last fetch for the subscribed list of topics and partitions
 *Get metadata about the partitions for a given topic. This method will issue a remote call to the server if it
 * does not already have any metadata about the given topic.
 *
 * @param topic The topic to get partition metadata for
 * @param timeout The maximum time this operation will block
 *
 * @return The list of partitions
 * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}
 * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this
 *             function is called
 * @throws org.apache.kafka.common.errors.InterruptException if the calling thread is interrupted before or while
 *             this function is called
 * @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 specified topic. See the exception for more details
 * @throws org.apache.kafka.common.errors.TimeoutException if the topic metadata could not be fetched before
 *             expiration of the configured request timeout
 * @throws org.apache.kafka.clientscommon.consumer.InvalidOffsetExceptionKafkaException iffor theany offsetother for a partition or set ofunrecoverable errors
 */
List<PartitionInfo> partitionsFor(String topic, Duration timeout);

/**
 * Get metadata about partitions for all topics that the user is authorized partitionsto isview. undefinedThis ormethod outwill ofissue rangea
 and* noremote offsetcall resetto policythe has been configuredserver.
 *
 * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this@param timeout The maximum time this operation will block
 *
 * @return The map of topics and       function is calledits partitions
 * @throws org.apache.kafka.common.errors.InterruptExceptionTimeoutException if thetime callingspent threadblocking isexceeds interruptedthe before or while{@code timeout}
 * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called before or while this
 *     this        function is called
 * @throws org.apache.kafka.common.errors.AuthenticationExceptionInterruptException if authenticationthe fails.calling Seethread theis exceptioninterrupted forbefore moreor detailswhile
 * @throws org.apache.kafka.common.errors.AuthorizationException if caller lacks Read access to any of the subscribed
 *             topics or to the configured groupId. See the exception for more details     this function is called
 * @throws org.apache.kafka.common.errors.TimeoutException if the topic metadata could not be fetched before
 *             expiration of the configured request timeout
 * @throws org.apache.kafka.common.KafkaException for any other unrecoverable errors (e.g. invalid groupId or
 */
Map<String, List<PartitionInfo>> listTopics(Duration timeout)

/**
 * Look up the offsets for the given partitions sessionby timeout,timestamp. errorsThe deserializingreturned key/value pairs, or any new error cases in future versions)
 * @throws java.lang.IllegalArgumentException if the timeout value is negative
 * @throws java.lang.IllegalStateException if the consumer is not subscribed to any topics or manually assigned any
 *             partitions to consume from
 */
public ConsumerRecords<K, V> poll(final Duration maxBlockTime)

/**
 * Get the first offset for the given partitions.
 * <p>
 * This method does not change the current consumer position of the partitions.
 *
 * @see #seekToBeginning(Collection)
 *
 * @param partitions the partitions to get the earliest offsets.
 * @param timeout The maximum time this operation will block
 *
 * @return The earliest available offsets for the given partitions
 * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}
 * @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(s). See the exception for more details
 * @throws org.apache.kafka.common.errors.TimeoutException if the offsets could not be fetched before
 *         expiration of the configured {@code request.timeout.ms}
 */
Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> partitions, Duration timeout)

/**
 * Get the end offsets for the given partitions. In the default {@code read_uncommitted} isolation level, the end
 * offset is the high watermark (that is, the offset of the last successfully replicated message plus one). For
 * {@code read_committed} consumers, the end offset is the last stable offset (LSO), which is the minimum of
 * the high watermark and the smallest offset of any open transaction. Finally, if the partition has never been
 * written to, the end offset is 0.
 *
 * <p>
 * This method does not change the current consumer position of the partitions.
 *
 * @see #seekToEnd(Collection)
 *
 * @param partitions the partitions to get the end offsets.
 * @param timeout The maximum time this operation will block
 *
 * @return The end offsets for the given partitions.
 * @throws org.apache.kafka.common.errors.TimeoutException if time spent blocking exceeds the {@code timeout}
 * @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(s). See the exception for more details
 * @throws org.apache.kafka.common.errors.TimeoutException if the offsets could not be fetched before
 *         expiration of the configured {@code request.timeout.ms}
 */
Map<TopicPartition, Long> endOffsets(Collection<TopicPartition> partitions, Duration timeout)

/**
 * Tries to close the consumer cleanly within the specified timeout. This method waits up to
 * {@code timeout} for the consumer to complete pending commits and leave the group.
 * If auto-commit is enabled, this will commit the current offsets if possible within the
 * timeout. If the consumer is unable to complete offset commits and gracefully leave the group
 * before the timeout expires, the consumer is force closed. Note that {@link #wakeup()} cannot be
 * used to interrupt close.
 *
 * @param timeout The maximum time to wait for consumer to close gracefully. The value must be
 *                non-negative. Specifying a timeout of zero means do not wait for pending requests to complete.
 *
 * @throws IllegalArgumentException If the {@code timeout} is negative.
 * @throws InterruptException If the thread is interrupted before or while this function is called
 * @throws org.apache.kafka.common.KafkaException for any other error during close
 */
public void close(Duration timeout)