You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2024/05/14 08:19:06 UTC
(kafka) branch trunk updated (e1771448cf1 -> 0587a9af3d3)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from e1771448cf1 MINOR: Add coverage for MM2 heartbeats topic detection (#15932)
add 0587a9af3d3 MINOR: Various cleanups in clients tests (#15877)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../kafka/clients/AddressChangeHostResolver.java | 4 +-
.../org/apache/kafka/clients/ClientUtilsTest.java | 2 +-
.../kafka/clients/ClusterConnectionStatesTest.java | 7 +-
.../kafka/clients/FetchSessionHandlerTest.java | 15 +--
.../apache/kafka/clients/InFlightRequestsTest.java | 2 +-
.../org/apache/kafka/clients/MetadataTest.java | 22 ++---
.../kafka/clients/admin/TopicCollectionTest.java | 8 +-
.../DeleteConsumerGroupOffsetsHandlerTest.java | 3 +-
.../internals/DeleteConsumerGroupsHandlerTest.java | 3 +-
.../DescribeConsumerGroupsHandlerTest.java | 3 +-
.../admin/internals/FenceProducersHandlerTest.java | 2 -
.../RemoveMembersFromConsumerGroupHandlerTest.java | 6 +-
.../consumer/ConsumerGroupMetadataTest.java | 2 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 83 ++++------------
.../clients/consumer/RoundRobinAssignorTest.java | 11 +--
.../internals/AbstractCoordinatorTest.java | 20 +---
.../consumer/internals/AsyncKafkaConsumerTest.java | 8 +-
.../internals/CommitRequestManagerTest.java | 4 +-
.../internals/ConsumerNetworkClientTest.java | 24 ++---
.../internals/ConsumerNetworkThreadTest.java | 7 --
.../internals/FetchRequestManagerTest.java | 59 ++++++------
.../clients/consumer/internals/FetcherTest.java | 57 ++++++-----
.../clients/consumer/internals/HeartbeatTest.java | 12 +--
.../internals/NetworkClientDelegateTest.java | 3 +-
.../consumer/internals/OffsetFetcherTest.java | 2 +-
.../internals/OffsetForLeaderEpochClientTest.java | 12 +--
.../events/ApplicationEventProcessorTest.java | 22 ++---
.../metrics/HeartbeatMetricsManagerTest.java | 4 +-
.../metrics/OffsetCommitMetricsManagerTest.java | 4 +-
.../RebalanceCallbackMetricsManagerTest.java | 4 +-
.../kafka/clients/producer/KafkaProducerTest.java | 18 ++--
.../internals/ProducerInterceptorsTest.java | 2 +-
.../producer/internals/ProducerMetadataTest.java | 10 +-
.../producer/internals/RecordAccumulatorTest.java | 51 +++++-----
.../clients/producer/internals/SenderTest.java | 45 +++++----
.../producer/internals/TransactionManagerTest.java | 30 ++----
.../apache/kafka/common/TopicPartitionTest.java | 7 +-
.../apache/kafka/common/config/ConfigDefTest.java | 4 +-
.../common/header/internals/RecordHeadersTest.java | 8 +-
.../apache/kafka/common/message/MessageTest.java | 2 +-
.../apache/kafka/common/metrics/MetricsTest.java | 10 +-
.../metrics/internals/IntGaugeSuiteTest.java | 3 +-
.../apache/kafka/common/network/CertStores.java | 6 +-
.../common/network/SaslChannelBuilderTest.java | 4 +-
.../apache/kafka/common/network/SelectorTest.java | 4 +-
.../kafka/common/network/SslSelectorTest.java | 7 +-
.../common/network/SslTransportLayerTest.java | 36 +++----
.../network/SslVersionsTransportLayerTest.java | 2 +-
.../kafka/common/protocol/MessageUtilTest.java | 2 +-
.../record/CompressionRatioEstimatorTest.java | 4 +-
.../common/record/DefaultRecordBatchTest.java | 2 +-
.../kafka/common/record/DefaultRecordTest.java | 2 +-
.../kafka/common/record/FileRecordsTest.java | 2 +-
.../common/record/UnalignedFileRecordsTest.java | 2 +-
.../requests/AddPartitionsToTxnRequestTest.java | 60 ++++++------
.../common/requests/DeleteAclsRequestTest.java | 4 +-
.../common/requests/DeleteGroupsResponseTest.java | 41 ++++----
.../common/requests/DescribeAclsRequestTest.java | 4 +-
.../common/requests/LeaveGroupRequestTest.java | 9 +-
.../common/requests/LeaveGroupResponseTest.java | 13 +--
.../common/requests/OffsetCommitRequestTest.java | 3 +-
.../common/requests/OffsetFetchRequestTest.java | 2 +-
.../requests/TxnOffsetCommitRequestTest.java | 22 ++---
.../requests/WriteTxnMarkersRequestTest.java | 26 ++---
.../requests/WriteTxnMarkersResponseTest.java | 20 ++--
.../ClientAuthenticationFailureTest.java | 7 +-
.../SaslAuthenticatorFailureDelayTest.java | 9 +-
.../authenticator/SaslAuthenticatorTest.java | 18 ++--
.../security/authenticator/TestJaasConfig.java | 2 +-
.../common/security/kerberos/KerberosNameTest.java | 10 +-
.../common/security/kerberos/KerberosRuleTest.java | 21 ++--
.../internals/OAuthBearerSaslClientTest.java | 2 +-
.../internals/OAuthBearerSaslServerTest.java | 5 -
.../ExpiringCredentialRefreshingLoginTest.java | 10 +-
.../internals/secured/RefreshingHttpsJwksTest.java | 2 +-
.../unsecured/OAuthBearerUnsecuredJwsTest.java | 8 +-
...uthBearerUnsecuredLoginCallbackHandlerTest.java | 6 +-
.../unsecured/OAuthBearerValidationUtilsTest.java | 4 +-
.../scram/internals/ScramMessagesTest.java | 2 +-
.../scram/internals/ScramSaslServerTest.java | 3 +-
...nNameLoggingTrustManagerFactoryWrapperTest.java | 2 +-
.../security/ssl/SslPrincipalMapperTest.java | 8 +-
.../security/ssl/mock/TestKeyManagerFactory.java | 4 +-
.../common/serialization/SerializationTest.java | 5 +-
.../kafka/common/utils/AbstractIteratorTest.java | 2 +-
.../apache/kafka/common/utils/ConfigUtilsTest.java | 13 +--
.../org/apache/kafka/common/utils/Crc32CTest.java | 4 +-
.../ImplicitLinkedHashMultiCollectionTest.java | 8 +-
.../apache/kafka/common/utils/MockScheduler.java | 6 +-
.../apache/kafka/common/utils/SanitizerTest.java | 2 +-
.../kafka/common/utils/SecurityUtilsTest.java | 8 +-
.../org/apache/kafka/common/utils/UtilsTest.java | 2 +-
.../java/org/apache/kafka/test/MetricsBench.java | 2 +-
.../org/apache/kafka/test/Microbenchmarks.java | 106 ++++++++++-----------
95 files changed, 488 insertions(+), 677 deletions(-)