[
https://issues.apache.org/jira/browse/KAFKA-18829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gunnar Morling updated KAFKA-18829:
-----------------------------------
Description:
I am getting the following exception when trying to acknowledge a message with
a share consumer and poll returns an empty batch of messages:
{code:java}
Exception in thread "main" java.lang.IllegalStateException: Implicit
acknowledgement of delivery is being used.
at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.ensureExplicitAcknowledgement(ShareConsumerImpl.java:1053)
at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.acknowledge(ShareConsumerImpl.java:681)
at
org.apache.kafka.clients.consumer.KafkaShareConsumer.acknowledge(KafkaShareConsumer.java:535)
{code}
This is as of commit 385b7ad3557196f8e84b34cc536f6dd2ac1fd502.
was:
I am getting the following exception when trying to acknowledge a message with
a share consumer and poll returns an empty batch of messages:
{code:java}
Exception in thread "main" java.lang.IllegalStateException: Implicit
acknowledgement of delivery is being used.
at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.ensureExplicitAcknowledgement(ShareConsumerImpl.java:1053)
at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.acknowledge(ShareConsumerImpl.java:681)
at
org.apache.kafka.clients.consumer.KafkaShareConsumer.acknowledge(KafkaShareConsumer.java:535)
{code}
> Can't use explicit ack when poll returns an empty batch
> -------------------------------------------------------
>
> Key: KAFKA-18829
> URL: https://issues.apache.org/jira/browse/KAFKA-18829
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Gunnar Morling
> Priority: Major
>
> I am getting the following exception when trying to acknowledge a message
> with a share consumer and poll returns an empty batch of messages:
>
> {code:java}
> Exception in thread "main" java.lang.IllegalStateException: Implicit
> acknowledgement of delivery is being used.
> at
> org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.ensureExplicitAcknowledgement(ShareConsumerImpl.java:1053)
> at
> org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.acknowledge(ShareConsumerImpl.java:681)
> at
> org.apache.kafka.clients.consumer.KafkaShareConsumer.acknowledge(KafkaShareConsumer.java:535)
> {code}
>
> This is as of commit 385b7ad3557196f8e84b34cc536f6dd2ac1fd502.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
