This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 715df0d MINOR: Improve log4j for per-consumer assignment (#8997)
add 9c8f75c KAFKA-10223; Use NOT_LEADER_OR_FOLLOWER instead of
non-retriable REPLICA_NOT_AVAILABLE for consumers (#8979)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/consumer/internals/Fetcher.java | 4 +-
.../internals/OffsetsForLeaderEpochClient.java | 2 +-
.../errors/NotLeaderForPartitionException.java | 4 +-
...tion.java => NotLeaderOrFollowerException.java} | 25 ++++++----
.../errors/ReplicaNotAvailableException.java | 8 +++-
.../org/apache/kafka/common/protocol/Errors.java | 10 ++--
.../common/requests/DeleteRecordsResponse.java | 2 +-
.../apache/kafka/common/requests/FetchRequest.java | 2 +-
.../kafka/common/requests/FetchResponse.java | 10 ++--
.../kafka/common/requests/ListOffsetResponse.java | 4 +-
.../requests/OffsetsForLeaderEpochResponse.java | 4 +-
.../kafka/common/requests/ProduceRequest.java | 2 +-
.../kafka/common/requests/ProduceResponse.java | 8 ++--
.../common/requests/WriteTxnMarkersResponse.java | 2 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 12 ++---
.../kafka/clients/consumer/KafkaConsumerTest.java | 2 +-
.../clients/consumer/internals/FetcherTest.java | 20 ++++----
.../clients/producer/internals/SenderTest.java | 20 ++++----
.../producer/internals/TransactionManagerTest.java | 12 ++---
.../common/requests/LeaderAndIsrResponseTest.java | 2 +-
.../common/requests/StopReplicaResponseTest.java | 2 +-
core/src/main/scala/kafka/cluster/Partition.scala | 21 ++++----
.../coordinator/group/GroupMetadataManager.scala | 4 +-
...TransactionMarkerRequestCompletionHandler.scala | 2 +-
.../transaction/TransactionStateManager.scala | 2 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 4 +-
.../scala/kafka/server/DelayedDeleteRecords.scala | 2 +-
.../src/main/scala/kafka/server/DelayedFetch.scala | 10 ++--
.../main/scala/kafka/server/DelayedProduce.scala | 2 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 6 +--
.../kafka/server/ReplicaAlterLogDirsThread.scala | 10 ++--
.../main/scala/kafka/server/ReplicaManager.scala | 56 +++++++++++-----------
.../kafka/api/PlaintextAdminIntegrationTest.scala | 2 +-
.../kafka/api/ProducerFailureHandlingTest.scala | 2 +-
.../kafka/server/DelayedFetchTest.scala | 12 ++---
.../scala/unit/kafka/cluster/PartitionTest.scala | 22 ++++-----
.../group/GroupMetadataManagerTest.scala | 4 +-
...sactionMarkerRequestCompletionHandlerTest.scala | 4 +-
.../transaction/TransactionStateManagerTest.scala | 2 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 4 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 14 +++---
.../unit/kafka/server/LogDirFailureTest.scala | 10 ++--
.../server/OffsetsForLeaderEpochRequestTest.scala | 8 ++--
.../unit/kafka/server/ProduceRequestTest.scala | 2 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 24 +++++-----
.../kafka/server/ReplicaFetcherThreadTest.scala | 2 +-
.../kafka/server/ReplicaManagerQuotasTest.scala | 3 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 54 +++++++++++++++------
.../server/epoch/LeaderEpochIntegrationTest.scala | 2 +-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 2 +-
docs/upgrade.html | 4 ++
52 files changed, 246 insertions(+), 209 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/{RecordBatchTooLargeException.java
=> NotLeaderOrFollowerException.java} (54%)
