[ https://issues.apache.org/jira/browse/KAFKA-19471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003779#comment-18003779 ]
Andrew Schofield commented on KAFKA-19471: ------------------------------------------ Sure. Go ahead. > Enable acknowledgement for a record which could not be deserialized > ------------------------------------------------------------------- > > Key: KAFKA-19471 > URL: https://issues.apache.org/jira/browse/KAFKA-19471 > Project: Kafka > Issue Type: Sub-task > Reporter: Andrew Schofield > Assignee: Lan Ding > Priority: Major > Fix For: 4.2.0 > > > If a record fetched by a share consumer fails to be deserialized, the KIP > states that it is automatically released and that the application cannot > override this behavior. Actually, experience with KafkaShareConsumer shows > that it would be helpful to be able to override this to REJECT such records > instead. > We can add an override `KafkaShareConsumer.acknowledge(String topic, int > partition, long offset, AcknowledgeType type)` for this purpose where the > user does not have a `ConsumerRecord` instance available, but they do know > the topic, partition and offset from the DeserializationException. The > validation of this information is exactly the same as for the same > information when it is implied by the `ConsumerRecord`. -- This message was sent by Atlassian Jira (v8.20.10#820010)