This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 1a176beff1b MINOR: Reword warning message when internal deprecated
properties are used (#20224)
add abbb6b3c13f KAFKA-19471: Enable acknowledgement for a record which
could not be deserialized (#20148)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/ShareConsumerTest.java | 152 ++++++++++++++++++++-
.../kafka/clients/consumer/KafkaShareConsumer.java | 22 +++
.../kafka/clients/consumer/MockShareConsumer.java | 4 +
.../kafka/clients/consumer/ShareConsumer.java | 5 +
.../consumer/internals/ShareCompletedFetch.java | 19 ++-
.../consumer/internals/ShareConsumerImpl.java | 17 +++
.../clients/consumer/internals/ShareFetch.java | 27 +++-
.../consumer/internals/ShareFetchCollector.java | 2 +-
.../consumer/internals/ShareFetchException.java} | 28 ++--
.../consumer/internals/ShareInFlightBatch.java | 8 +-
...trics.java => ShareInFlightBatchException.java} | 24 +++-
.../internals/ShareCompletedFetchTest.java | 8 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
.../apache/kafka/common/test/ClusterInstance.java | 15 +-
14 files changed, 287 insertions(+), 46 deletions(-)
copy
clients/src/main/java/org/apache/kafka/{common/errors/SerializationException.java
=> clients/consumer/internals/ShareFetchException.java} (61%)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/{ShareConsumerMetrics.java
=> ShareInFlightBatchException.java} (62%)
