Removed / breaking in @show, gone in @4.3.1
ClientRequest.attachmentMethodts/src/main/java/org/apache/kafka/clients/ClientRequest.java
ClientRequest.createdTimeMethodts/src/main/java/org/apache/kafka/clients/ClientRequest.java
ClientRequest.requestMethodts/src/main/java/org/apache/kafka/clients/ClientRequest.java
ClientResponse.receivedTimeMethods/src/main/java/org/apache/kafka/clients/ClientResponse.java
ClientResponse.requestMethods/src/main/java/org/apache/kafka/clients/ClientResponse.java
ClusterConnectionStates.connectedMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
InFlightRequests.inFlightRequestCountMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
KafkaClient.nextRequestHeaderMethodents/src/main/java/org/apache/kafka/clients/KafkaClient.java
NetworkClient.correlateMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.handleMetadataResponseMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.isSendableMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.maybeUpdateMetadataMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.metadataRequestMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.nextRequestHeaderMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NodeConnectionStateClass/main/java/org/apache/kafka/clients/NodeConnectionState.java
NodeConnectionState.NodeConnectionStateMethod/main/java/org/apache/kafka/clients/NodeConnectionState.java
NodeConnectionState.toStringMethod/main/java/org/apache/kafka/clients/NodeConnectionState.java
Consumer.commitMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.offsetsBeforeTimeMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
ConsumerRebalanceCallbackInterfaceapache/kafka/clients/consumer/ConsumerRebalanceCallback.java
ConsumerRebalanceCallback.onPartitionsAssignedMethodapache/kafka/clients/consumer/ConsumerRebalanceCallback.java
ConsumerRebalanceCallback.onPartitionsRevokedMethodapache/kafka/clients/consumer/ConsumerRebalanceCallback.java
ConsumerRecord.errorMethodn/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
ConsumerRecord.topicAndPartitionMethodn/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
ConsumerRecords.topicMethod/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
KafkaConsumer.addDeserializerToConfigMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.commitMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.offsetsBeforeTimeMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
MockConsumer.commitMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.offsetsBeforeTimeMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
OffsetMetadataClassn/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
OffsetMetadata.OffsetMetadataMethodn/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
OffsetMetadata.errorMethodn/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
OffsetMetadata.offsetMethodn/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
KafkaProducer.addSerializerToConfigMethodin/java/org/apache/kafka/clients/producer/KafkaProducer.java
KafkaProducer.parseAcksMethodin/java/org/apache/kafka/clients/producer/KafkaProducer.java
FutureRecordMetadata.relativeOffsetMethode/kafka/clients/producer/internals/FutureRecordMetadata.java
MetadataClassva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.MetadataMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.addMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.awaitUpdateMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.fetchMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.lastUpdateMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.refreshBackoffMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.requestUpdateMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.timeToNextUpdateMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.topicsMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
Metadata.updateMethodva/org/apache/kafka/clients/producer/internals/Metadata.java
PartitionerClassorg/apache/kafka/clients/producer/internals/Partitioner.java
Partitioner.partitionMethodorg/apache/kafka/clients/producer/internals/Partitioner.java
RecordAccumulator.dequeForMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.hasUnsentMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.measureMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordBatchClassorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.RecordBatchMethodorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.ThunkClassorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.Thunk.ThunkMethodorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.doneMethodorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.toStringMethodorg/apache/kafka/clients/producer/internals/RecordBatch.java
RecordBatch.tryAppendMethodorg/apache/kafka/clients/producer/internals/RecordBatch.java
Sender.SenderMetrics.measureMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.createProduceRequestsMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.handleDisconnectMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.handleResponseMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.produceRequestMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
ProducerPerformanceClassjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.PerfCallbackClassjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.PerfCallback.PerfCallbackMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.PerfCallback.onCompletionMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.StatsClassjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.StatsMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.newWindowMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.nextCompletionMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.percentilesMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.printTotalMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.printWindowMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.Stats.recordMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
ProducerPerformance.mainMethodjava/org/apache/kafka/clients/tools/ProducerPerformance.java
Metric.valueMethodclients/src/main/java/org/apache/kafka/common/Metric.java
MetricName.getTagsMethodlients/src/main/java/org/apache/kafka/common/MetricName.java
PartitionInfo.fmtNodeIdsMethodnts/src/main/java/org/apache/kafka/common/PartitionInfo.java
ConfigDef.ValidString.joinMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
NotLeaderForPartitionExceptionClassache/kafka/common/errors/NotLeaderForPartitionException.java
NotLeaderForPartitionException.NotLeaderForPartitionExceptionMethodache/kafka/common/errors/NotLeaderForPartitionException.java
SerializationException.fillInStackTraceMethoda/org/apache/kafka/common/errors/SerializationException.java
KafkaLZ4BlockInputStreamClassrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.KafkaLZ4BlockInputStreamMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.availableMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.closeMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.markMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.markSupportedMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.readMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.readBlockMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.readHeaderMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.resetMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockInputStream.skipMethodrg/apache/kafka/common/message/KafkaLZ4BlockInputStream.java
KafkaLZ4BlockOutputStreamClassg/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
KafkaLZ4BlockOutputStream.BDClassg/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
KafkaLZ4BlockOutputStream.BD.BDMethodg/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
KafkaLZ4BlockOutputStream.BD.fromByteMethodg/apache/kafka/common/message/KafkaLZ4BlockOutputStream.java
… +652 more
Signature changed
ClientRequest.ClientRequestMethodts/src/main/java/org/apache/kafka/clients/ClientRequest.java
ClientResponse.ClientResponseMethods/src/main/java/org/apache/kafka/clients/ClientResponse.java
ClusterConnectionStates.ClusterConnectionStatesMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.canConnectMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.connectingMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.connectionDelayMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.disconnectedMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.isBlackedOutMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.isConnectedMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.isConnectingMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
ClusterConnectionStates.nodeStateMethodn/java/org/apache/kafka/clients/ClusterConnectionStates.java
InFlightRequests.addMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.canSendMoreMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.clearAllMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.completeLastSentMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.completeNextMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.lastSentMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
InFlightRequests.requestQueueMethodsrc/main/java/org/apache/kafka/clients/InFlightRequests.java
KafkaClient.closeMethodents/src/main/java/org/apache/kafka/clients/KafkaClient.java
KafkaClient.pollMethodents/src/main/java/org/apache/kafka/clients/KafkaClient.java
NetworkClient.NetworkClientMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.closeMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
NetworkClient.pollMethodts/src/main/java/org/apache/kafka/clients/NetworkClient.java
Consumer.committedMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.pollMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.positionMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.seekMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.subscribeMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
Consumer.unsubscribeMethodrc/main/java/org/apache/kafka/clients/consumer/Consumer.java
ConsumerConfig.ConsumerConfigMethodn/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
ConsumerRecord.ConsumerRecordMethodn/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
ConsumerRecords.ConsumerRecordsMethod/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
ConsumerRecords.recordsMethod/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
KafkaConsumer.committedMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.pollMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.positionMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.seekMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.subscribeMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
KafkaConsumer.unsubscribeMethodin/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
MockConsumer.MockConsumerMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.committedMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.pollMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.positionMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.seekMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.subscribeMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
MockConsumer.unsubscribeMethodain/java/org/apache/kafka/clients/consumer/MockConsumer.java
KafkaProducer.KafkaProducerMethodin/java/org/apache/kafka/clients/producer/KafkaProducer.java
KafkaProducer.sendMethodin/java/org/apache/kafka/clients/producer/KafkaProducer.java
KafkaProducer.waitOnMetadataMethodin/java/org/apache/kafka/clients/producer/KafkaProducer.java
MockProducer.Completion.CompletionMethodain/java/org/apache/kafka/clients/producer/MockProducer.java
MockProducer.MockProducerMethodain/java/org/apache/kafka/clients/producer/MockProducer.java
MockProducer.sendMethodain/java/org/apache/kafka/clients/producer/MockProducer.java
Producer.sendMethodrc/main/java/org/apache/kafka/clients/producer/Producer.java
ProducerConfig.ProducerConfigMethodn/java/org/apache/kafka/clients/producer/ProducerConfig.java
ProducerRecord.ProducerRecordMethodn/java/org/apache/kafka/clients/producer/ProducerRecord.java
RecordMetadata.RecordMetadataMethodn/java/org/apache/kafka/clients/producer/RecordMetadata.java
BufferPool.BufferPoolMethod/org/apache/kafka/clients/producer/internals/BufferPool.java
BufferPool.allocateMethod/org/apache/kafka/clients/producer/internals/BufferPool.java
FutureRecordMetadata.FutureRecordMetadataMethode/kafka/clients/producer/internals/FutureRecordMetadata.java
ProduceRequestResult.ProduceRequestResultMethode/kafka/clients/producer/internals/ProduceRequestResult.java
ProduceRequestResult.doneMethode/kafka/clients/producer/internals/ProduceRequestResult.java
ProduceRequestResult.errorMethode/kafka/clients/producer/internals/ProduceRequestResult.java
RecordAccumulator.ReadyCheckResult.ReadyCheckResultMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.RecordAccumulatorMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.RecordAppendResult.RecordAppendResultMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.appendMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.deallocateMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.drainMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.readyMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.reenqueueMethodache/kafka/clients/producer/internals/RecordAccumulator.java
RecordAccumulator.registerMetricsMethodache/kafka/clients/producer/internals/RecordAccumulator.java
Sender.SenderMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.SenderMetrics.SenderMetricsMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.SenderMetrics.recordLatencyMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.SenderMetrics.updateProduceRequestMetricsMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.canRetryMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Sender.completeBatchMethodjava/org/apache/kafka/clients/producer/internals/Sender.java
Cluster.ClusterMethodclients/src/main/java/org/apache/kafka/common/Cluster.java
AbstractConfig.AbstractConfigMethodmain/java/org/apache/kafka/common/config/AbstractConfig.java
AbstractConfig.getConfiguredInstanceMethodmain/java/org/apache/kafka/common/config/AbstractConfig.java
ConfigDef.ConfigKey.ConfigKeyMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
ConfigDef.ValidString.inMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
ConfigDef.compareMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
ConfigDef.defineMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
Validator.ensureValidMethod/src/main/java/org/apache/kafka/common/config/ConfigDef.java
NotEnoughReplicasAfterAppendException.NotEnoughReplicasAfterAppendExceptionMethodfka/common/errors/NotEnoughReplicasAfterAppendException.java
OffsetOutOfRangeException.OffsetOutOfRangeExceptionMethodrg/apache/kafka/common/errors/OffsetOutOfRangeException.java
JmxReporter.getMBeanNameMethodc/main/java/org/apache/kafka/common/metrics/JmxReporter.java
KafkaMetric.KafkaMetricMethodc/main/java/org/apache/kafka/common/metrics/KafkaMetric.java
QuotaViolationException.QuotaViolationExceptionMethodorg/apache/kafka/common/metrics/QuotaViolationException.java
Sensor.SensorMethodts/src/main/java/org/apache/kafka/common/metrics/Sensor.java
Sensor.checkQuotasMethodts/src/main/java/org/apache/kafka/common/metrics/Sensor.java
ByteBufferSend.ByteBufferSendMethodain/java/org/apache/kafka/common/network/ByteBufferSend.java
ByteBufferSend.writeToMethodain/java/org/apache/kafka/common/network/ByteBufferSend.java
NetworkReceive.NetworkReceiveMethodain/java/org/apache/kafka/common/network/NetworkReceive.java
NetworkSend.NetworkSendMethodc/main/java/org/apache/kafka/common/network/NetworkSend.java
Selectable.connectMethodrc/main/java/org/apache/kafka/common/network/Selectable.java
Selectable.pollMethodrc/main/java/org/apache/kafka/common/network/Selectable.java
Selector.SelectorMethod/src/main/java/org/apache/kafka/common/network/Selector.java
Selector.SelectorMetrics.SelectorMetricsMethod/src/main/java/org/apache/kafka/common/network/Selector.java
… +87 more
Added new API surface in @4.3.1
ClientRebootstrapTestClassest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.consumerRebootstrapMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.consumerRebootstrapDisabledMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testAdminRebootstrapMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testAdminRebootstrapDisabledMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testClassicConsumerRebootstrapMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testClassicConsumerRebootstrapDisabledMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testConsumerRebootstrapMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testConsumerRebootstrapDisabledMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testProducerRebootstrapMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientRebootstrapTest.testProducerRebootstrapDisabledMethodest/java/org/apache/kafka/clients/ClientRebootstrapTest.java
ClientsTestUtilsClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.BaseConsumerTestcaseClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.BaseConsumerTestcase.BaseConsumerTestcaseMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.BaseConsumerTestcase.testClusterResourceListenerMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.BaseConsumerTestcase.testCoordinatorFailoverMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.BaseConsumerTestcase.testSimpleConsumptionMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.ClientsTestUtilsMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.RetryCommitCallbackClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.RetryCommitCallback.RetryCommitCallbackMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.RetryCommitCallback.onCompleteMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerDeserializerClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerDeserializer.deserializeMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerDeserializer.onUpdateMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerDeserializer.resetCountMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerSerializerClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerSerializer.onUpdateMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerSerializer.resetCountMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestClusterResourceListenerSerializer.serializeMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestConsumerReassignmentListenerClasssrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestConsumerReassignmentListener.onPartitionsAssignedMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.TestConsumerReassignmentListener.onPartitionsRevokedMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.awaitAssignmentMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.awaitRebalanceMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.consumeAndVerifyRecordsMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.consumeAndVerifyRecordsWithTimeTypeLogAppendMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.consumeRecordsMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.ensureNoRebalanceMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.pollUntilTrueMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.sendAndAwaitAsyncCommitMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.sendAsyncCommitMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.sendRecordMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.sendRecordsMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
ClientsTestUtils.waitForPollThrowExceptionMethodsrc/test/java/org/apache/kafka/clients/ClientsTestUtils.java
CreateTopicsRequestWithPolicyTestClass/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.PolicyClass/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.Policy.closeMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.Policy.configureMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.Policy.validateMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.testErrorCreateTopicsRequestsMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.testValidCreateTopicsRequestsMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.validateErrorCreateTopicsRequestsMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
CreateTopicsRequestWithPolicyTest.validateValidCreateTopicsRequestsMethod/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
MetadataVersionIntegrationTestClassorg/apache/kafka/clients/MetadataVersionIntegrationTest.java
MetadataVersionIntegrationTest.testBasicMetadataVersionUpgradeMethodorg/apache/kafka/clients/MetadataVersionIntegrationTest.java
MetadataVersionIntegrationTest.testDefaultIsLatestVersionMethodorg/apache/kafka/clients/MetadataVersionIntegrationTest.java
MetadataVersionIntegrationTest.testUpgradeSameVersionMethodorg/apache/kafka/clients/MetadataVersionIntegrationTest.java
MetricsDuringTopicCreationDeletionTestClasshe/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
MetricsDuringTopicCreationDeletionTest.MetricsDuringTopicCreationDeletionTestMethodhe/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
MetricsDuringTopicCreationDeletionTest.createAndDeleteTopicsMethodhe/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
MetricsDuringTopicCreationDeletionTest.getGaugeMethodhe/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDeleteMethodhe/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
TransactionsExpirationTestClassava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.assertConsumeRecordsMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.producerStateMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testFatalErrorAfterInvalidProducerIdMappingMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testFatalErrorAfterInvalidProducerIdMappingWithTV1Methodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testFatalErrorAfterInvalidProducerIdMappingWithTV2Methodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testTransactionAfterProducerIdExpiresMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testTransactionAfterProducerIdExpiresWithTV1Methodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.testTransactionAfterProducerIdExpiresWithTV2Methodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.waitUntilTransactionalStateExistsMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsExpirationTest.waitUntilTransactionalStateExpiresMethodava/org/apache/kafka/clients/TransactionsExpirationTest.java
TransactionsWithMaxInFlightOneTestClassapache/kafka/clients/TransactionsWithMaxInFlightOneTest.java
TransactionsWithMaxInFlightOneTest.testTransactionalProducerSingleBrokerMaxInFlightOneMethodapache/kafka/clients/TransactionsWithMaxInFlightOneTest.java
AdminClientWithPoliciesIntegrationTestClasska/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.AdminClientWithPoliciesIntegrationTestMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.PolicyClasska/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.Policy.closeMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.Policy.configureMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.Policy.validateMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.setupMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.testInvalidAlterConfigsDueToPolicyMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminClientWithPoliciesIntegrationTest.validationsForResourceMethodka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
AdminFenceProducersTestClass/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AdminFenceProducersTest.AdminFenceProducersTestMethod/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AdminFenceProducersTest.createProducerMethod/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AdminFenceProducersTest.testFenceAfterProducerCommitMethod/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AdminFenceProducersTest.testFenceBeforeProducerCommitMethod/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AdminFenceProducersTest.testFenceProducerTimeoutMsMethod/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
AutoTopicCreationTestClassva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
AutoTopicCreationTest.testAutoCreateTopicWithDefaultConfigMethodva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
AutoTopicCreationTest.testAutoCreateTopicWithExplicitBrokerConfigMethodva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
AutoTopicCreationTest.testAutoCreateTopicWithImplicitBrokerConfigMethodva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
AutoTopicCreationTest.testAutoCreateTopicWithMixedConfigMethodva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
AutoTopicCreationTest.triggerAutoCreateTopicMethodva/org/apache/kafka/clients/admin/AutoTopicCreationTest.java
ClientTelemetryTestClassjava/org/apache/kafka/clients/admin/ClientTelemetryTest.java
ClientTelemetryTest.TelemetryExporterClassjava/org/apache/kafka/clients/admin/ClientTelemetryTest.java
ClientTelemetryTest.TelemetryExporter.clientTelemetryExporterMethodjava/org/apache/kafka/clients/admin/ClientTelemetryTest.java
ClientTelemetryTest.TelemetryExporter.closeMethodjava/org/apache/kafka/clients/admin/ClientTelemetryTest.java
… +76434 more