ShareConsumer (clients 7.9.6-ce API)

All Superinterfaces:
AutoCloseable, Closeable
All Known Implementing Classes:
KafkaShareConsumer, MockShareConsumer
```
@InterfaceStability.Evolving
public interface ShareConsumer<K,V>
extends Closeable
```
See Also:
KafkaShareConsumer, MockShareConsumer

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`acknowledge(ConsumerRecord<K,V> record)`
`void`	`acknowledge(ConsumerRecord<K,V> record, AcknowledgeType type)`
`Uuid`	`clientInstanceId(Duration timeout)` See `KafkaShareConsumer.clientInstanceId(Duration)`}
`void`	`close()`
`void`	`close(Duration timeout)`
`void`	`commitAsync()`
`Map<TopicIdPartition,Optional<KafkaException>>`	`commitSync()`
`Map<TopicIdPartition,Optional<KafkaException>>`	`commitSync(Duration timeout)`
`Map<MetricName,? extends Metric>`	`metrics()`
`ConsumerRecords<K,V>`	`poll(Duration timeout)`
`void`	`setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)`
`void`	`subscribe(Collection<String> topics)`
`Set<String>`	`subscription()`
`void`	`unsubscribe()`
`void`	`wakeup()`

- Method Detail
  - subscription
```
Set<String> subscription()
```
    See Also:
    KafkaShareConsumer.subscription()
  - subscribe
```
void subscribe(Collection<String> topics)
```
    See Also:
    KafkaShareConsumer.subscribe(Collection)
  - unsubscribe
```
void unsubscribe()
```
    See Also:
    KafkaShareConsumer.unsubscribe()
  - poll
```
ConsumerRecords<K,V> poll(Duration timeout)
```
    See Also:
    KafkaShareConsumer.poll(Duration)
  - acknowledge
```
void acknowledge(ConsumerRecord<K,V> record)
```
    See Also:
    KafkaShareConsumer.acknowledge(ConsumerRecord)
  - acknowledge
```
void acknowledge(ConsumerRecord<K,V> record,
                 AcknowledgeType type)
```
    See Also:
    KafkaShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType)
  - commitSync
```
Map<TopicIdPartition,Optional<KafkaException>> commitSync()
```
    See Also:
    KafkaShareConsumer.commitSync()
  - commitSync
```
Map<TopicIdPartition,Optional<KafkaException>> commitSync(Duration timeout)
```
    See Also:
    KafkaShareConsumer.commitSync(Duration)
  - commitAsync
```
void commitAsync()
```
    See Also:
    KafkaShareConsumer.commitAsync()
  - setAcknowledgementCommitCallback
```
void setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)
```
    See Also:
    KafkaShareConsumer.setAcknowledgementCommitCallback(AcknowledgementCommitCallback)
  - clientInstanceId
```
Uuid clientInstanceId(Duration timeout)
```
    See KafkaShareConsumer.clientInstanceId(Duration)}
  - metrics
```
Map<MetricName,? extends Metric> metrics()
```
    See Also:
    KafkaShareConsumer.metrics()
  - close
```
void close()
```
    Specified by:
    close in interface AutoCloseable
    Specified by:
    close in interface Closeable
    See Also:
    KafkaShareConsumer.close()
  - close
```
void close(Duration timeout)
```
    See Also:
    KafkaShareConsumer.close(Duration)
  - wakeup
```
void wakeup()
```
    See Also:
    KafkaShareConsumer.wakeup()

Interface ShareConsumer<K,V>

Method Summary

Method Detail

subscription

subscribe

unsubscribe

poll

acknowledge

acknowledge

commitSync

commitSync

commitAsync

setAcknowledgementCommitCallback

clientInstanceId

metrics

close

close

wakeup