Upgrading org.apache.kafka:kafka-clients 0.11 to 1

Unknown0.11.0.3 → 1.1.1

Full comparison Back to org.apache.kafka:kafka-clients

Fetching 5 releases from Maven Central…0 / 5

UnknownUpgrade verdict

DepDelta is still reading the notes for this range, so breaking changes can't be ruled out yet.

In plain terms

DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
This page updates as the notes come in.

Must act Still reading release notes

DepDelta is still reading the release notes in this range. This updates as they come in.

Adds org.lz4:lz4-java 1.4.1.

Drops net.jpountz.lz4:lz4.

API changes

Generated by DepDelta from published JVM bytecode. Not mixed with prose notes.

removed: ctor ClientUtils()
removed: ctor NetworkClientUtils()
removed: method NodeApiVersions.usableVersion(ApiKeys): short
removed: method NodeApiVersions.usableVersion(ApiKeys, Short): short
changed: class ClientUtils → final class ClientUtils
changed: class NetworkClientUtils → final class NetworkClientUtils
changed: ctor NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, Time, boolean, ApiVersions) → ctor NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, Time, boolean, ApiVersions, LogContext)
changed: ctor NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, Time, boolean, ApiVersions, Sensor) → ctor NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, Time, boolean, ApiVersions, Sensor, LogContext)
changed: ctor NetworkClient(Selectable, MetadataUpdater, String, int, long, long, int, int, int, Time, boolean, ApiVersions) → ctor NetworkClient(Selectable, MetadataUpdater, String, int, long, long, int, int, int, Time, boolean, ApiVersions, LogContext)
changed: method Metadata.failedUpdate(long): void → method Metadata.failedUpdate(long, AuthenticationException): void
added: class FetchSessionHandler
added: class FetchSessionHandler.Builder
added: ctor FetchSessionHandler(LogContext, int)
added: ctor FetchSessionHandler.Builder(FetchSessionHandler)
added: method ConnectionState.isDisconnected(): boolean
added: method FetchSessionHandler.Builder.add(TopicPartition, FetchRequest.PartitionData): void
added: method FetchSessionHandler.Builder.build(): FetchSessionHandler.FetchRequestData
added: method FetchSessionHandler.FetchRequestData.metadata(): FetchMetadata
added: method FetchSessionHandler.FetchRequestData.sessionPartitions(): Map
added: method FetchSessionHandler.FetchRequestData.toForget(): List
added: method FetchSessionHandler.FetchRequestData.toSend(): Map
added: method FetchSessionHandler.FetchRequestData.toString(): String
added: method FetchSessionHandler.handleError(Throwable): void
added: method FetchSessionHandler.handleResponse(FetchResponse): boolean
added: method FetchSessionHandler.newBuilder(): FetchSessionHandler.Builder
added: method KafkaClient.authenticationException(Node): AuthenticationException
added: method ManualMetadataUpdater.handleAuthenticationFailure(AuthenticationException): void
added: method Metadata.getAndClearAuthenticationException(): AuthenticationException
added: method NetworkClient.authenticationException(Node): AuthenticationException
added: method NodeApiVersions.latestUsableVersion(ApiKeys): short
added: method NodeApiVersions.latestUsableVersion(ApiKeys, short, short): short
added: static class FetchSessionHandler.FetchRequestData
added: static field CommonClientConfigs.RETRIES_CONFIG: String
added: static field CommonClientConfigs.RETRIES_DOC: String
added: static field ConnectionState.AUTHENTICATION_FAILED: ConnectionState

removed: method AlterConfigsOptions.timeoutMs(): Integer
removed: method CreateAclsOptions.timeoutMs(): Integer
removed: method CreateTopicsOptions.timeoutMs(): Integer
removed: method DeleteAclsOptions.timeoutMs(): Integer
removed: method DeleteTopicsOptions.timeoutMs(): Integer
removed: method DescribeAclsOptions.timeoutMs(): Integer
removed: method DescribeClusterOptions.timeoutMs(): Integer
removed: method DescribeConfigsOptions.timeoutMs(): Integer
removed: method DescribeTopicsOptions.timeoutMs(): Integer
removed: method ListTopicsOptions.timeoutMs(): Integer
changed: class AlterConfigsOptions → class AlterConfigsOptions extends AbstractOptions
changed: class CreateAclsOptions → class CreateAclsOptions extends AbstractOptions
changed: class CreateTopicsOptions → class CreateTopicsOptions extends AbstractOptions
changed: class DeleteAclsOptions → class DeleteAclsOptions extends AbstractOptions
changed: class DeleteTopicsOptions → class DeleteTopicsOptions extends AbstractOptions
changed: class DescribeAclsOptions → class DescribeAclsOptions extends AbstractOptions
changed: class DescribeClusterOptions → class DescribeClusterOptions extends AbstractOptions
changed: class DescribeConfigsOptions → class DescribeConfigsOptions extends AbstractOptions
changed: class DescribeTopicsOptions → class DescribeTopicsOptions extends AbstractOptions
changed: class ListTopicsOptions → class ListTopicsOptions extends AbstractOptions
added: abstract class AbstractOptions
added: class AlterReplicaLogDirsOptions extends AbstractOptions
added: class AlterReplicaLogDirsResult
added: class CreatePartitionsOptions extends AbstractOptions
added: class CreatePartitionsResult
added: class DeleteRecordsOptions extends AbstractOptions
added: class DeleteRecordsResult
added: class DeletedRecords
added: class DescribeLogDirsOptions extends AbstractOptions
added: class DescribeLogDirsResult
added: class DescribeReplicaLogDirsOptions extends AbstractOptions
added: class DescribeReplicaLogDirsResult
added: class NewPartitions
added: class RecordsToDelete
added: ctor AbstractOptions()
added: ctor AlterReplicaLogDirsOptions()
added: ctor CreatePartitionsOptions()
added: ctor DeleteRecordsOptions()
added: ctor DeleteRecordsResult(Map)
added: ctor DeletedRecords(long)
added: ctor DescribeLogDirsOptions()
added: ctor DescribeReplicaLogDirsOptions()
added: enum ConfigEntry.ConfigSource
added: field AbstractOptions.timeoutMs: Integer
added: method AbstractOptions.timeoutMs(): Integer
added: method AbstractOptions.timeoutMs(Integer): AbstractOptions
added: method AdminClient.alterReplicaLogDirs(Map): AlterReplicaLogDirsResult
added: method AdminClient.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions): AlterReplicaLogDirsResult
added: method AdminClient.createPartitions(Map): CreatePartitionsResult
added: method AdminClient.createPartitions(Map, CreatePartitionsOptions): CreatePartitionsResult
added: method AdminClient.deleteRecords(Map): DeleteRecordsResult
added: method AdminClient.deleteRecords(Map, DeleteRecordsOptions): DeleteRecordsResult
added: method AdminClient.describeLogDirs(Collection): DescribeLogDirsResult
added: method AdminClient.describeLogDirs(Collection, DescribeLogDirsOptions): DescribeLogDirsResult
added: method AdminClient.describeReplicaLogDirs(Collection): DescribeReplicaLogDirsResult
added: method AdminClient.describeReplicaLogDirs(Collection, DescribeReplicaLogDirsOptions): DescribeReplicaLogDirsResult
added: method AlterReplicaLogDirsResult.all(): KafkaFuture
added: method AlterReplicaLogDirsResult.values(): Map
added: method ConfigEntry.ConfigSynonym.equals(Object): boolean
added: method ConfigEntry.ConfigSynonym.hashCode(): int
added: method ConfigEntry.ConfigSynonym.name(): String
added: method ConfigEntry.ConfigSynonym.source(): ConfigEntry.ConfigSource
added: method ConfigEntry.ConfigSynonym.toString(): String
added: method ConfigEntry.ConfigSynonym.value(): String
added: method ConfigEntry.equals(Object): boolean
added: method ConfigEntry.hashCode(): int
added: method ConfigEntry.source(): ConfigEntry.ConfigSource
added: method ConfigEntry.synonyms(): List
added: method CreatePartitionsOptions.validateOnly(): boolean
added: method CreatePartitionsOptions.validateOnly(boolean): CreatePartitionsOptions
added: method CreatePartitionsResult.all(): KafkaFuture
added: method CreatePartitionsResult.values(): Map
added: method DeleteRecordsResult.all(): KafkaFuture
added: method DeleteRecordsResult.lowWatermarks(): Map
added: method DeletedRecords.lowWatermark(): long
added: method DescribeConfigsOptions.includeSynonyms(): boolean
added: method DescribeConfigsOptions.includeSynonyms(boolean): DescribeConfigsOptions
added: method DescribeLogDirsResult.all(): KafkaFuture
added: method DescribeLogDirsResult.values(): Map
added: method DescribeReplicaLogDirsResult.ReplicaLogDirInfo.getCurrentReplicaLogDir(): String
added: method DescribeReplicaLogDirsResult.ReplicaLogDirInfo.getCurrentReplicaOffsetLag(): long
added: method DescribeReplicaLogDirsResult.ReplicaLogDirInfo.getFutureReplicaLogDir(): String
added: method DescribeReplicaLogDirsResult.ReplicaLogDirInfo.getFutureReplicaOffsetLag(): long
added: method DescribeReplicaLogDirsResult.ReplicaLogDirInfo.toString(): String
added: method DescribeReplicaLogDirsResult.all(): KafkaFuture
added: method DescribeReplicaLogDirsResult.values(): Map
added: method KafkaAdminClient.alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions): AlterReplicaLogDirsResult
added: method KafkaAdminClient.createPartitions(Map, CreatePartitionsOptions): CreatePartitionsResult
added: method KafkaAdminClient.deleteRecords(Map, DeleteRecordsOptions): DeleteRecordsResult
added: method KafkaAdminClient.describeLogDirs(Collection, DescribeLogDirsOptions): DescribeLogDirsResult
added: method KafkaAdminClient.describeReplicaLogDirs(Collection, DescribeReplicaLogDirsOptions): DescribeReplicaLogDirsResult
added: method NewPartitions.assignments(): List
added: method NewPartitions.toString(): String
added: method NewPartitions.totalCount(): int
added: method NewTopic.configs(): Map
added: method RecordsToDelete.beforeOffset(): long
added: method RecordsToDelete.equals(Object): boolean
added: method RecordsToDelete.hashCode(): int
added: method RecordsToDelete.toString(): String
added: method TopicDescription.equals(Object): boolean
added: method TopicDescription.hashCode(): int
added: static class ConfigEntry.ConfigSynonym
added: static class DescribeReplicaLogDirsResult.ReplicaLogDirInfo
added: static field ConfigEntry.ConfigSource.DEFAULT_CONFIG: ConfigEntry.ConfigSource
added: static field ConfigEntry.ConfigSource.DYNAMIC_BROKER_CONFIG: ConfigEntry.ConfigSource
added: static field ConfigEntry.ConfigSource.DYNAMIC_DEFAULT_BROKER_CONFIG: ConfigEntry.ConfigSource
added: static field ConfigEntry.ConfigSource.DYNAMIC_TOPIC_CONFIG: ConfigEntry.ConfigSource
added: static field ConfigEntry.ConfigSource.STATIC_BROKER_CONFIG: ConfigEntry.ConfigSource
added: static field ConfigEntry.ConfigSource.UNKNOWN: ConfigEntry.ConfigSource
added: static method ConfigEntry.ConfigSource.valueOf(String): ConfigEntry.ConfigSource
added: static method ConfigEntry.ConfigSource.values(): ConfigEntry.ConfigSource[]
added: static method NewPartitions.increaseTo(int): NewPartitions
added: static method NewPartitions.increaseTo(int, List): NewPartitions
added: static method RecordsToDelete.beforeOffset(long): RecordsToDelete

added: ctor ConsumerConfig(Map)
added: ctor ConsumerConfig(Properties)
added: method Consumer.subscribe(Pattern): void
added: method KafkaConsumer.subscribe(Pattern): void
added: method MockConsumer.addEndOffsets(Map): void
added: method MockConsumer.subscribe(Pattern): void

removed: method AbstractCoordinator.coordinator(): Node
removed: method AbstractCoordinator.coordinatorDead(): void
removed: method ConsumerCoordinator.maybeAutoCommitOffsetsNow(): void
removed: method ConsumerNetworkClient.failUnsentRequests(Node, RuntimeException): void
removed: method Fetcher.getOffsetsByTimes(Map, long): Map
removed: method Fetcher.updateFetchPositions(Set): void
removed: method SubscriptionState.commitsRefreshed(): void
removed: method SubscriptionState.committed(TopicPartition): OffsetAndMetadata
removed: method SubscriptionState.committed(TopicPartition, OffsetAndMetadata): void
removed: method SubscriptionState.hasAllFetchPositions(Collection): boolean
removed: method SubscriptionState.listener(): ConsumerRebalanceListener
removed: method SubscriptionState.needOffsetReset(TopicPartition): void
removed: method SubscriptionState.needOffsetReset(TopicPartition, OffsetResetStrategy): void
removed: method SubscriptionState.needRefreshCommits(): void
removed: method SubscriptionState.refreshCommitsNeeded(): boolean
removed: static method RequestFuture.leaderNotAvailable(): RequestFuture
removed: static method RequestFuture.staleMetadata(): RequestFuture
changed: ctor AbstractCoordinator(ConsumerNetworkClient, String, int, int, int, Metrics, String, Time, long, boolean) → ctor AbstractCoordinator(LogContext, ConsumerNetworkClient, String, int, int, int, Metrics, String, Time, long, boolean)
changed: ctor ConsumerCoordinator(ConsumerNetworkClient, String, int, int, int, List, Metadata, SubscriptionState, Metrics, String, Time, long, boolean, int, ConsumerInterceptors, boolean, boolean) → ctor ConsumerCoordinator(LogContext, ConsumerNetworkClient, String, int, int, int, List, Metadata, SubscriptionState, Metrics, String, Time, long, boolean, int, ConsumerInterceptors, boolean, boolean)
changed: ctor ConsumerNetworkClient(KafkaClient, Metadata, Time, long, long) → ctor ConsumerNetworkClient(LogContext, KafkaClient, Metadata, Time, long, long, int)
changed: ctor Fetcher(ConsumerNetworkClient, int, int, int, int, int, boolean, Deserializer, Deserializer, Metadata, SubscriptionState, Metrics, FetcherMetricsRegistry, Time, long, IsolationLevel) → ctor Fetcher(LogContext, ConsumerNetworkClient, int, int, int, int, int, boolean, Deserializer, Deserializer, Metadata, SubscriptionState, Metrics, FetcherMetricsRegistry, Time, long, long, IsolationLevel)
changed: method Fetcher.resetOffsetsIfNeeded(Set): void → method Fetcher.resetOffsetsIfNeeded(): void
added: field FetcherMetricsRegistry.bytesConsumedTotal: MetricNameTemplate
added: field FetcherMetricsRegistry.fetchRequestTotal: MetricNameTemplate
added: field FetcherMetricsRegistry.partitionRecordsLagAvgDeprecated: MetricNameTemplate
added: field FetcherMetricsRegistry.partitionRecordsLagDeprecated: MetricNameTemplate
added: field FetcherMetricsRegistry.partitionRecordsLagMaxDeprecated: MetricNameTemplate
added: field FetcherMetricsRegistry.recordsConsumedTotal: MetricNameTemplate
added: field FetcherMetricsRegistry.topicBytesConsumedTotal: MetricNameTemplate
added: field FetcherMetricsRegistry.topicRecordsConsumedTotal: MetricNameTemplate
added: method AbstractCoordinator.checkAndGetCoordinator(): Node
added: method AbstractCoordinator.createMeter(Metrics, String, String, String): Meter
added: method AbstractCoordinator.markCoordinatorUnknown(): void
added: method AbstractCoordinator.markCoordinatorUnknown(boolean): void
added: method ConsumerCoordinator.maybeAutoCommitOffsetsAsync(long): void
added: method ConsumerNetworkClient.disconnectAsync(Node): void
added: method Fetcher.offsetsByTimes(Map, long): Map
added: method SubscriptionState.partitionsNeedingReset(long): Set
added: method SubscriptionState.rebalanceListener(): ConsumerRebalanceListener
added: method SubscriptionState.requestOffsetReset(TopicPartition): void
added: method SubscriptionState.requestOffsetReset(TopicPartition, OffsetResetStrategy): void
added: method SubscriptionState.resetFailed(Set, long): void
added: method SubscriptionState.resetMissingPositions(): void
added: method SubscriptionState.setResetPending(Set, long): void
added: static field AbstractCoordinator.HEARTBEAT_THREAD_PREFIX: String

added: ctor ProducerConfig(Map)
added: ctor ProducerConfig(Properties)
added: method RecordMetadata.hasOffset(): boolean
added: method RecordMetadata.hasTimestamp(): boolean
added: static field KafkaProducer.NETWORK_THREAD_PREFIX: String

removed: field TransactionManager.logPrefix: String
removed: method ProducerBatch.sizeInBytes(): int
changed: ctor RecordAccumulator(int, long, CompressionType, long, long, Metrics, Time, ApiVersions, TransactionManager) → ctor RecordAccumulator(LogContext, int, long, CompressionType, long, long, Metrics, Time, ApiVersions, TransactionManager)
changed: ctor Sender(KafkaClient, Metadata, RecordAccumulator, boolean, int, short, int, Metrics, Time, int, long, TransactionManager, ApiVersions) → ctor Sender(LogContext, KafkaClient, Metadata, RecordAccumulator, boolean, int, short, int, SenderMetricsRegistry, Time, int, long, TransactionManager, ApiVersions)
changed: ctor TransactionManager(String, int, long) → ctor TransactionManager(LogContext, String, int, long)
changed: method ProducerBatch.done(long, long, RuntimeException): void → method ProducerBatch.done(long, long, RuntimeException): boolean
changed: static method Sender.throttleTimeSensor(Metrics): Sensor → static method Sender.throttleTimeSensor(SenderMetricsRegistry): Sensor
added: class ProducerMetrics
added: class SenderMetricsRegistry
added: ctor ProducerMetrics(Metrics)
added: ctor SenderMetricsRegistry(Metrics)
added: field ProducerMetrics.senderMetrics: SenderMetricsRegistry
added: field SenderMetricsRegistry.batchSizeAvg: MetricName
added: field SenderMetricsRegistry.batchSizeMax: MetricName
added: field SenderMetricsRegistry.batchSplitRate: MetricName
added: field SenderMetricsRegistry.batchSplitTotal: MetricName
added: field SenderMetricsRegistry.compressionRateAvg: MetricName
added: field SenderMetricsRegistry.metadataAge: MetricName
added: field SenderMetricsRegistry.produceThrottleTimeAvg: MetricName
added: field SenderMetricsRegistry.produceThrottleTimeMax: MetricName
added: field SenderMetricsRegistry.recordErrorRate: MetricName
added: field SenderMetricsRegistry.recordErrorTotal: MetricName
added: field SenderMetricsRegistry.recordQueueTimeAvg: MetricName
added: field SenderMetricsRegistry.recordQueueTimeMax: MetricName
added: field SenderMetricsRegistry.recordRetryRate: MetricName
added: field SenderMetricsRegistry.recordRetryTotal: MetricName
added: field SenderMetricsRegistry.recordSendRate: MetricName
added: field SenderMetricsRegistry.recordSendTotal: MetricName
added: field SenderMetricsRegistry.recordSizeAvg: MetricName
added: field SenderMetricsRegistry.recordSizeMax: MetricName
added: field SenderMetricsRegistry.recordsPerRequestAvg: MetricName
added: field SenderMetricsRegistry.requestLatencyAvg: MetricName
added: field SenderMetricsRegistry.requestLatencyMax: MetricName
added: field SenderMetricsRegistry.requestsInFlight: MetricName
added: method ProducerBatch.baseSequence(): int
added: method ProducerBatch.estimatedSizeInBytes(): int
added: method ProducerBatch.hasSequence(): boolean
added: method ProducerBatch.isTransactional(): boolean
added: method ProducerBatch.resetProducerState(ProducerIdAndEpoch, int, boolean): void
added: method ProducerBatch.sequenceHasBeenReset(): boolean
added: method SenderMetricsRegistry.addMetric(MetricName, Measurable): void
added: method SenderMetricsRegistry.allTemplates(): List
added: method SenderMetricsRegistry.getSensor(String): Sensor
added: method SenderMetricsRegistry.sensor(String): Sensor
added: method SenderMetricsRegistry.topicByteRate(Map): MetricName
added: method SenderMetricsRegistry.topicByteTotal(Map): MetricName
added: method SenderMetricsRegistry.topicCompressionRate(Map): MetricName
added: method SenderMetricsRegistry.topicRecordErrorRate(Map): MetricName
added: method SenderMetricsRegistry.topicRecordErrorTotal(Map): MetricName
added: method SenderMetricsRegistry.topicRecordRetryRate(Map): MetricName
added: method SenderMetricsRegistry.topicRecordRetryTotal(Map): MetricName
added: method SenderMetricsRegistry.topicRecordSendRate(Map): MetricName
added: method SenderMetricsRegistry.topicRecordSendTotal(Map): MetricName
added: static method ProducerMetrics.main(String[]): void

removed: ctor KafkaFuture.BiConsumer()
removed: method KafkaFuture.Function.apply(Object): Object
removed: static abstract class KafkaFuture.BiConsumer
changed: static abstract class KafkaFuture.Function → static abstract class KafkaFuture.Function implements KafkaFuture.BaseFunction
added: ctor PartitionInfo(String, int, Node, Node[], Node[], Node[])
added: ctor TopicPartitionReplica(String, int, int)
added: final class TopicPartitionReplica implements Serializable
added: interface KafkaFuture.BaseFunction
added: interface KafkaFuture.BiConsumer
added: interface Reconfigurable extends Configurable
added: method KafkaFuture.BaseFunction.apply(Object): Object
added: method KafkaFuture.thenApply(KafkaFuture.BaseFunction): KafkaFuture
added: method KafkaFuture.whenComplete(KafkaFuture.BiConsumer): KafkaFuture
added: method Metric.metricValue(): Object
added: method MetricNameTemplate.equals(Object): boolean
added: method MetricNameTemplate.hashCode(): int
added: method MetricNameTemplate.toString(): String
added: method PartitionInfo.offlineReplicas(): Node[]
added: method Reconfigurable.reconfigurableConfigs(): Set
added: method Reconfigurable.reconfigure(Map): void
added: method Reconfigurable.validateReconfiguration(Map): void
added: method TopicPartitionInfo.equals(Object): boolean
added: method TopicPartitionInfo.hashCode(): int
added: method TopicPartitionReplica.brokerId(): int
added: method TopicPartitionReplica.equals(Object): boolean
added: method TopicPartitionReplica.hashCode(): int
added: method TopicPartitionReplica.partition(): int
added: method TopicPartitionReplica.toString(): String
added: method TopicPartitionReplica.topic(): String

added: ctor ConfigDef.NonEmptyStringWithoutControlChars()
added: ctor ConfigDef.NonNullValidator()
added: method AbstractConfig.getConfiguredInstances(List, Class, Map): List
added: method AbstractConfig.originalsWithPrefix(String, boolean): Map
added: method AbstractConfig.valuesWithPrefixAllOrNothing(String): Map
added: method ConfigDef.CompositeValidator.ensureValid(String, Object): void
added: method ConfigDef.NonEmptyStringWithoutControlChars.ensureValid(String, Object): void
added: method ConfigDef.NonNullValidator.ensureValid(String, Object): void
added: method ConfigDef.defaultValues(): Map
added: method ConfigDef.toHtmlTable(Map): String
added: method ConfigResource.isDefault(): boolean
added: static class ConfigDef.CompositeValidator implements ConfigDef.Validator
added: static class ConfigDef.NonEmptyStringWithoutControlChars implements ConfigDef.Validator
added: static class ConfigDef.NonNullValidator implements ConfigDef.Validator
added: static field SslConfigs.RECONFIGURABLE_CONFIGS: Set
added: static method ConfigDef.CompositeValidator.of(ConfigDef.Validator[]): ConfigDef.CompositeValidator
added: static method ConfigDef.NonEmptyStringWithoutControlChars.nonEmptyStringWithoutControlChars(): ConfigDef.NonEmptyStringWithoutControlChars
added: static method ConfigDef.convertToStringMapWithPasswordValues(Map): Map

added: class BrokerSecurityConfigs
added: ctor BrokerSecurityConfigs()
added: static field BrokerSecurityConfigs.DEFAULT_SASL_ENABLED_MECHANISMS: List
added: static field BrokerSecurityConfigs.DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES: List
added: static field BrokerSecurityConfigs.PRINCIPAL_BUILDER_CLASS_CONFIG: String
added: static field BrokerSecurityConfigs.PRINCIPAL_BUILDER_CLASS_DOC: String
added: static field BrokerSecurityConfigs.SASL_ENABLED_MECHANISMS_CONFIG: String
added: static field BrokerSecurityConfigs.SASL_ENABLED_MECHANISMS_DOC: String
added: static field BrokerSecurityConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_CONFIG: String
added: static field BrokerSecurityConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_DOC: String
added: static field BrokerSecurityConfigs.SSL_CLIENT_AUTH_CONFIG: String
added: static field BrokerSecurityConfigs.SSL_CLIENT_AUTH_DOC: String

removed: class DuplicateSequenceNumberException extends RetriableException
removed: ctor DuplicateSequenceNumberException(String)
added: class DelegationTokenAuthorizationException extends AuthorizationException
added: class DelegationTokenDisabledException extends ApiException
added: class DelegationTokenExpiredException extends ApiException
added: class DelegationTokenNotFoundException extends ApiException
added: class DelegationTokenOwnerMismatchException extends ApiException
added: class DuplicateSequenceException extends ApiException
added: class FetchSessionIdNotFoundException extends RetriableException
added: class GroupIdNotFoundException extends ApiException
added: class GroupNotEmptyException extends ApiException
added: class InvalidFetchSessionEpochException extends RetriableException
added: class InvalidPrincipalTypeException extends ApiException
added: class KafkaStorageException extends InvalidMetadataException
added: class LogDirNotFoundException extends ApiException
added: class ReassignmentInProgressException extends ApiException
added: class SaslAuthenticationException extends AuthenticationException
added: class SslAuthenticationException extends AuthenticationException
added: class UnknownProducerIdException extends OutOfOrderSequenceException
added: class UnsupportedByAuthenticationException extends ApiException
added: ctor DelegationTokenAuthorizationException(String)
added: ctor DelegationTokenAuthorizationException(String, Throwable)
added: ctor DelegationTokenDisabledException(String)
added: ctor DelegationTokenDisabledException(String, Throwable)
added: ctor DelegationTokenExpiredException(String)
added: ctor DelegationTokenExpiredException(String, Throwable)
added: ctor DelegationTokenNotFoundException(String)
added: ctor DelegationTokenNotFoundException(String, Throwable)
added: ctor DelegationTokenOwnerMismatchException(String)
added: ctor DelegationTokenOwnerMismatchException(String, Throwable)
added: ctor DuplicateSequenceException(String)
added: ctor FetchSessionIdNotFoundException()
added: ctor FetchSessionIdNotFoundException(String)
added: ctor GroupIdNotFoundException(String)
added: ctor GroupNotEmptyException(String)
added: ctor InvalidFetchSessionEpochException()
added: ctor InvalidFetchSessionEpochException(String)
added: ctor InvalidPrincipalTypeException(String)
added: ctor InvalidPrincipalTypeException(String, Throwable)
added: ctor KafkaStorageException()
added: ctor KafkaStorageException(String)
added: ctor KafkaStorageException(String, Throwable)
added: ctor KafkaStorageException(Throwable)
added: ctor LogDirNotFoundException(String)
added: ctor LogDirNotFoundException(String, Throwable)
added: ctor LogDirNotFoundException(Throwable)
added: ctor ReassignmentInProgressException(String)
added: ctor ReassignmentInProgressException(String, Throwable)
added: ctor SaslAuthenticationException(String)
added: ctor SaslAuthenticationException(String, Throwable)
added: ctor SslAuthenticationException(String)
added: ctor SslAuthenticationException(String, Throwable)
added: ctor UnknownProducerIdException(String)
added: ctor UnsupportedByAuthenticationException(String)
added: ctor UnsupportedByAuthenticationException(String, Throwable)
added: method GroupIdNotFoundException.groupId(): String
added: method GroupNotEmptyException.groupId(): String

added: method KafkaFutureImpl.thenApply(KafkaFuture.BaseFunction): KafkaFuture
added: method KafkaFutureImpl.toString(): String
added: method KafkaFutureImpl.whenComplete(KafkaFuture.BiConsumer): KafkaFuture

added: class GarbageCollectedMemoryPool extends SimpleMemoryPool implements AutoCloseable
added: class SimpleMemoryPool implements MemoryPool
added: ctor GarbageCollectedMemoryPool(long, int, boolean, Sensor)
added: ctor SimpleMemoryPool(long, int, boolean, Sensor)
added: field SimpleMemoryPool.availableMemory: AtomicLong
added: field SimpleMemoryPool.log: Logger
added: field SimpleMemoryPool.maxSingleAllocationSize: int
added: field SimpleMemoryPool.sizeBytes: long
added: field SimpleMemoryPool.startOfNoMemPeriod: AtomicLong
added: field SimpleMemoryPool.strict: boolean
added: interface MemoryPool
added: method GarbageCollectedMemoryPool.bufferToBeReleased(ByteBuffer): void
added: method GarbageCollectedMemoryPool.bufferToBeReturned(ByteBuffer): void
added: method GarbageCollectedMemoryPool.close(): void
added: method GarbageCollectedMemoryPool.toString(): String
added: method MemoryPool.availableMemory(): long
added: method MemoryPool.isOutOfMemory(): boolean
added: method MemoryPool.release(ByteBuffer): void
added: method MemoryPool.size(): long
added: method MemoryPool.tryAllocate(int): ByteBuffer
added: method SimpleMemoryPool.availableMemory(): long
added: method SimpleMemoryPool.bufferToBeReleased(ByteBuffer): void
added: method SimpleMemoryPool.bufferToBeReturned(ByteBuffer): void
added: method SimpleMemoryPool.isOutOfMemory(): boolean
added: method SimpleMemoryPool.maybeRecordEndOfDrySpell(): void
added: method SimpleMemoryPool.release(ByteBuffer): void
added: method SimpleMemoryPool.size(): long
added: method SimpleMemoryPool.toString(): String
added: method SimpleMemoryPool.tryAllocate(int): ByteBuffer
added: static field MemoryPool.NONE: MemoryPool

changed: ctor KafkaMetric(Object, MetricName, Measurable, MetricConfig, Time) → ctor KafkaMetric(Object, MetricName, MetricValueProvider, MetricConfig, Time)
changed: interface Measurable → interface Measurable extends MetricValueProvider
changed: static method Metrics.toHtmlTable(String, List): String → static method Metrics.toHtmlTable(String, Iterable): String
added: interface Gauge extends MetricValueProvider
added: interface MetricValueProvider
added: method Gauge.value(MetricConfig, long): Object
added: method KafkaMetric.metricValue(): Object
added: method Metrics.addMetric(MetricName, MetricConfig, MetricValueProvider): void
added: method Metrics.addMetric(MetricName, MetricValueProvider): void
added: method Metrics.removeReporter(MetricsReporter): void

added: class Frequencies extends SampledStat implements CompoundStat
added: class Frequency
added: class Meter implements CompoundStat
added: ctor Frequencies(int, double, double, Frequency[])
added: ctor Frequency(MetricName, double)
added: ctor Meter(MetricName, MetricName)
added: ctor Meter(SampledStat, MetricName, MetricName)
added: ctor Meter(TimeUnit, MetricName, MetricName)
added: ctor Meter(TimeUnit, SampledStat, MetricName, MetricName)
added: method Frequencies.combine(List, MetricConfig, long): double
added: method Frequencies.frequency(MetricConfig, long, double): double
added: method Frequencies.newSample(long): Frequencies.HistogramSample
added: method Frequencies.stats(): List
added: method Frequencies.update(SampledStat.Sample, MetricConfig, double, long): void
added: method Frequency.centerValue(): double
added: method Frequency.name(): MetricName
added: method Meter.record(MetricConfig, double, long): void
added: method Meter.stats(): List
added: static method Frequencies.forBooleanValues(MetricName, MetricName): Frequencies

removed: class DefaultAuthenticator implements Authenticator
removed: ctor DefaultAuthenticator()
removed: enum ChannelState
removed: method Authenticator.configure(TransportLayer, PrincipalBuilder, Map): void
removed: method ChannelBuilder.configure(Map): void
removed: method DefaultAuthenticator.authenticate(): void
removed: method DefaultAuthenticator.close(): void
removed: method DefaultAuthenticator.complete(): boolean
removed: method DefaultAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
removed: method DefaultAuthenticator.principal(): Principal
removed: method KafkaChannel.mute(): void
removed: method KafkaChannel.unmute(): void
removed: method SaslChannelBuilder.buildTransportLayer(String, SelectionKey, SocketChannel): TransportLayer
removed: static method ChannelState.valueOf(String): ChannelState
removed: static method ChannelState.values(): ChannelState[]
changed: class SaslChannelBuilder implements ChannelBuilder → class SaslChannelBuilder implements ChannelBuilder, ListenerReconfigurable
changed: class SslChannelBuilder implements ChannelBuilder → class SslChannelBuilder implements ChannelBuilder, ListenerReconfigurable
changed: ctor KafkaChannel(String, TransportLayer, Authenticator, int) → ctor KafkaChannel(String, TransportLayer, Authenticator, int, MemoryPool)
changed: ctor MultiSend(String, List) → ctor MultiSend(String, Queue)
changed: ctor SaslChannelBuilder(Mode, JaasContext, SecurityProtocol, String, boolean, CredentialCache) → ctor SaslChannelBuilder(Mode, Map, SecurityProtocol, ListenerName, boolean, String, boolean, CredentialCache, DelegationTokenCache)
changed: ctor Selector(int, long, Metrics, Time, String, Map, boolean, ChannelBuilder) → ctor Selector(int, long, Metrics, Time, String, Map, boolean, ChannelBuilder, LogContext)
changed: ctor Selector(int, long, Metrics, Time, String, Map, boolean, boolean, ChannelBuilder) → ctor Selector(int, long, Metrics, Time, String, Map, boolean, boolean, ChannelBuilder, MemoryPool, LogContext)
changed: ctor Selector(long, Metrics, Time, String, ChannelBuilder) → ctor Selector(long, Metrics, Time, String, ChannelBuilder, LogContext)
changed: ctor SslChannelBuilder(Mode) → ctor SslChannelBuilder(Mode, ListenerName, boolean)
changed: interface ChannelBuilder extends AutoCloseable → interface ChannelBuilder extends AutoCloseable, Configurable
changed: interface Receive → interface Receive extends Closeable
changed: method Authenticator.principal(): Principal → method Authenticator.principal(): KafkaPrincipal
changed: method ChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel → method ChannelBuilder.buildChannel(String, SelectionKey, int, MemoryPool): KafkaChannel
changed: method KafkaChannel.principal(): Principal → method KafkaChannel.principal(): KafkaPrincipal
changed: method PlaintextChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel → method PlaintextChannelBuilder.buildChannel(String, SelectionKey, int, MemoryPool): KafkaChannel
changed: method SaslChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel → method SaslChannelBuilder.buildChannel(String, SelectionKey, int, MemoryPool): KafkaChannel
changed: method SslChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel → method SslChannelBuilder.buildChannel(String, SelectionKey, int, MemoryPool): KafkaChannel
changed: static method ChannelBuilders.serverChannelBuilder(ListenerName, SecurityProtocol, AbstractConfig, CredentialCache): ChannelBuilder → static method ChannelBuilders.serverChannelBuilder(ListenerName, boolean, SecurityProtocol, AbstractConfig, CredentialCache, DelegationTokenCache): ChannelBuilder
added: class ChannelState
added: ctor ChannelState(ChannelState.State)
added: ctor ChannelState(ChannelState.State, AuthenticationException)
added: ctor NetworkReceive(int, String, MemoryPool)
added: enum ChannelState.State
added: interface ListenerReconfigurable extends Reconfigurable
added: method ChannelState.exception(): AuthenticationException
added: method ChannelState.state(): ChannelState.State
added: method KafkaChannel.equals(Object): boolean
added: method KafkaChannel.hasBytesBuffered(): boolean
added: method KafkaChannel.hashCode(): int
added: method KafkaChannel.isInMutableState(): boolean
added: method KafkaChannel.selectionKey(): SelectionKey
added: method ListenerName.saslMechanismConfigPrefix(String): String
added: method ListenerReconfigurable.listenerName(): ListenerName
added: method NetworkReceive.close(): void
added: method NetworkReceive.memoryAllocated(): boolean
added: method NetworkReceive.requiredMemoryAmountKnown(): boolean
added: method PlaintextTransportLayer.hasBytesBuffered(): boolean
added: method PlaintextTransportLayer.selectionKey(): SelectionKey
added: method Receive.memoryAllocated(): boolean
added: method Receive.requiredMemoryAmountKnown(): boolean
added: method SaslChannelBuilder.buildClientAuthenticator(Map, String, String, String, TransportLayer, Subject): SaslClientAuthenticator
added: method SaslChannelBuilder.buildServerAuthenticator(Map, String, TransportLayer, Map): SaslServerAuthenticator
added: method SaslChannelBuilder.listenerName(): ListenerName
added: method SaslChannelBuilder.reconfigurableConfigs(): Set
added: method SaslChannelBuilder.reconfigure(Map): void
added: method SaslChannelBuilder.validateReconfiguration(Map): void
added: method Selector.doConnect(SocketChannel, InetSocketAddress): boolean
added: method SslChannelBuilder.listenerName(): ListenerName
added: method SslChannelBuilder.reconfigurableConfigs(): Set
added: method SslChannelBuilder.reconfigure(Map): void
added: method SslChannelBuilder.validateReconfiguration(Map): void
added: method SslTransportLayer.appReadBuffer(): ByteBuffer
added: method SslTransportLayer.flush(ByteBuffer): boolean
added: method SslTransportLayer.hasBytesBuffered(): boolean
added: method SslTransportLayer.readFromSocketChannel(): int
added: method SslTransportLayer.selectionKey(): SelectionKey
added: method TransportLayer.hasBytesBuffered(): boolean
added: method TransportLayer.selectionKey(): SelectionKey
added: static field ChannelState.State.AUTHENTICATE: ChannelState.State
added: static field ChannelState.State.AUTHENTICATION_FAILED: ChannelState.State
added: static field ChannelState.State.EXPIRED: ChannelState.State
added: static field ChannelState.State.FAILED_SEND: ChannelState.State
added: static field ChannelState.State.LOCAL_CLOSE: ChannelState.State
added: static field ChannelState.State.NOT_CONNECTED: ChannelState.State
added: static field ChannelState.State.READY: ChannelState.State
added: static method ChannelBuilders.createPrincipalBuilder(Map, TransportLayer, Authenticator, KerberosShortNamer): KafkaPrincipalBuilder
added: static method ChannelState.State.valueOf(String): ChannelState.State
added: static method ChannelState.State.values(): ChannelState.State[]

removed: enum SecurityProtocol
removed: field SecurityProtocol.id: short
removed: field SecurityProtocol.name: String
removed: static field ApiKeys.CONTROLLED_SHUTDOWN_KEY: ApiKeys
removed: static field ApiKeys.UPDATE_METADATA_KEY: ApiKeys
removed: static field Errors.UNKNOWN: Errors
removed: static field Protocol.ADD_OFFSETS_TO_TXN_REQUEST: Schema[]
removed: static field Protocol.ADD_OFFSETS_TO_TXN_REQUEST_V0: Schema
removed: static field Protocol.ADD_OFFSETS_TO_TXN_RESPONSE: Schema[]
removed: static field Protocol.ADD_OFFSETS_TO_TXN_RESPONSE_V0: Schema
removed: static field Protocol.ADD_PARTITIONS_TO_TXN_REQUEST: Schema[]
removed: static field Protocol.ADD_PARTITIONS_TO_TXN_REQUEST_V0: Schema
removed: static field Protocol.ADD_PARTITIONS_TO_TXN_RESPONSE: Schema[]
removed: static field Protocol.ADD_PARTITIONS_TO_TXN_RESPONSE_V0: Schema
removed: static field Protocol.ALTER_CONFIGS_REQUEST: Schema[]
removed: static field Protocol.ALTER_CONFIGS_REQUEST_RESOURCE_V0: Schema
removed: static field Protocol.ALTER_CONFIGS_REQUEST_V0: Schema
removed: static field Protocol.ALTER_CONFIGS_RESPONSE: Schema[]
removed: static field Protocol.ALTER_CONFIGS_RESPONSE_ENTITY_V0: Schema
removed: static field Protocol.ALTER_CONFIGS_RESPONSE_V0: Schema
removed: static field Protocol.API_VERSIONS_REQUEST: Schema[]
removed: static field Protocol.API_VERSIONS_REQUEST_V0: Schema
removed: static field Protocol.API_VERSIONS_REQUEST_V1: Schema
removed: static field Protocol.API_VERSIONS_RESPONSE: Schema[]
removed: static field Protocol.API_VERSIONS_RESPONSE_V0: Schema
removed: static field Protocol.API_VERSIONS_RESPONSE_V1: Schema
removed: static field Protocol.API_VERSIONS_V0: Schema
removed: static field Protocol.CONFIG_ENTRY: Schema
removed: static field Protocol.CONTROLLED_SHUTDOWN_PARTITION_V1: Schema
removed: static field Protocol.CONTROLLED_SHUTDOWN_REQUEST: Schema[]
removed: static field Protocol.CONTROLLED_SHUTDOWN_REQUEST_V1: Schema
removed: static field Protocol.CONTROLLED_SHUTDOWN_RESPONSE: Schema[]
removed: static field Protocol.CONTROLLED_SHUTDOWN_RESPONSE_V1: Schema
removed: static field Protocol.CREATE_ACLS_REQUEST: Schema[]
removed: static field Protocol.CREATE_ACLS_REQUEST_V0: Schema
removed: static field Protocol.CREATE_ACLS_RESPONSE: Schema[]
removed: static field Protocol.CREATE_ACLS_RESPONSE_V0: Schema
removed: static field Protocol.CREATE_TOPICS_REQUEST: Schema[]
removed: static field Protocol.CREATE_TOPICS_REQUEST_V0: Schema
removed: static field Protocol.CREATE_TOPICS_REQUEST_V1: Schema
removed: static field Protocol.CREATE_TOPICS_REQUEST_V2: Schema
removed: static field Protocol.CREATE_TOPICS_RESPONSE: Schema[]
removed: static field Protocol.CREATE_TOPICS_RESPONSE_V0: Schema
removed: static field Protocol.CREATE_TOPICS_RESPONSE_V1: Schema
removed: static field Protocol.CREATE_TOPICS_RESPONSE_V2: Schema
removed: static field Protocol.DELETE_ACLS_REQUEST: Schema[]
removed: static field Protocol.DELETE_ACLS_REQUEST_V0: Schema
removed: static field Protocol.DELETE_ACLS_RESPONSE: Schema[]
removed: static field Protocol.DELETE_ACLS_RESPONSE_V0: Schema
removed: static field Protocol.DELETE_RECORDS_REQUEST: Schema[]
removed: static field Protocol.DELETE_RECORDS_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.DELETE_RECORDS_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.DELETE_RECORDS_REQUEST_V0: Schema
removed: static field Protocol.DELETE_RECORDS_RESPONSE: Schema[]
removed: static field Protocol.DELETE_RECORDS_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.DELETE_RECORDS_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.DELETE_RECORDS_RESPONSE_V0: Schema
removed: static field Protocol.DELETE_TOPICS_REQUEST: Schema[]
removed: static field Protocol.DELETE_TOPICS_REQUEST_V0: Schema
removed: static field Protocol.DELETE_TOPICS_REQUEST_V1: Schema
removed: static field Protocol.DELETE_TOPICS_RESPONSE: Schema[]
removed: static field Protocol.DELETE_TOPICS_RESPONSE_V0: Schema
removed: static field Protocol.DELETE_TOPICS_RESPONSE_V1: Schema
removed: static field Protocol.DESCRIBE_ACLS_REQUEST: Schema[]
removed: static field Protocol.DESCRIBE_ACLS_REQUEST_V0: Schema
removed: static field Protocol.DESCRIBE_ACLS_RESOURCE: Schema
removed: static field Protocol.DESCRIBE_ACLS_RESPONSE: Schema[]
removed: static field Protocol.DESCRIBE_ACLS_RESPONSE_V0: Schema
removed: static field Protocol.DESCRIBE_CONFIGS_REQUEST: Schema[]
removed: static field Protocol.DESCRIBE_CONFIGS_REQUEST_RESOURCE_V0: Schema
removed: static field Protocol.DESCRIBE_CONFIGS_REQUEST_V0: Schema
removed: static field Protocol.DESCRIBE_CONFIGS_RESPONSE: Schema[]
removed: static field Protocol.DESCRIBE_CONFIGS_RESPONSE_ENTITY_V0: Schema
removed: static field Protocol.DESCRIBE_CONFIGS_RESPONSE_V0: Schema
removed: static field Protocol.DESCRIBE_GROUPS_REQUEST: Schema[]
removed: static field Protocol.DESCRIBE_GROUPS_REQUEST_V0: Schema
removed: static field Protocol.DESCRIBE_GROUPS_REQUEST_V1: Schema
removed: static field Protocol.DESCRIBE_GROUPS_RESPONSE: Schema[]
removed: static field Protocol.DESCRIBE_GROUPS_RESPONSE_GROUP_METADATA_V0: Schema
removed: static field Protocol.DESCRIBE_GROUPS_RESPONSE_MEMBER_V0: Schema
removed: static field Protocol.DESCRIBE_GROUPS_RESPONSE_V0: Schema
removed: static field Protocol.DESCRIBE_GROUPS_RESPONSE_V1: Schema
removed: static field Protocol.END_TXN_REQUEST: Schema[]
removed: static field Protocol.END_TXN_REQUEST_V0: Schema
removed: static field Protocol.END_TXN_RESPONSE: Schema[]
removed: static field Protocol.END_TXN_RESPONSE_V0: Schema
removed: static field Protocol.FETCH_REQUEST: Schema[]
removed: static field Protocol.FETCH_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.FETCH_REQUEST_PARTITION_V5: Schema
removed: static field Protocol.FETCH_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.FETCH_REQUEST_TOPIC_V5: Schema
removed: static field Protocol.FETCH_REQUEST_V0: Schema
removed: static field Protocol.FETCH_REQUEST_V1: Schema
removed: static field Protocol.FETCH_REQUEST_V2: Schema
removed: static field Protocol.FETCH_REQUEST_V3: Schema
removed: static field Protocol.FETCH_REQUEST_V4: Schema
removed: static field Protocol.FETCH_REQUEST_V5: Schema
removed: static field Protocol.FETCH_RESPONSE: Schema[]
removed: static field Protocol.FETCH_RESPONSE_ABORTED_TRANSACTION_V5: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_HEADER_V0: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_HEADER_V4: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_HEADER_V5: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_V4: Schema
removed: static field Protocol.FETCH_RESPONSE_PARTITION_V5: Schema
removed: static field Protocol.FETCH_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.FETCH_RESPONSE_TOPIC_V4: Schema
removed: static field Protocol.FETCH_RESPONSE_TOPIC_V5: Schema
removed: static field Protocol.FETCH_RESPONSE_V0: Schema
removed: static field Protocol.FETCH_RESPONSE_V1: Schema
removed: static field Protocol.FETCH_RESPONSE_V2: Schema
removed: static field Protocol.FETCH_RESPONSE_V3: Schema
removed: static field Protocol.FETCH_RESPONSE_V4: Schema
removed: static field Protocol.FETCH_RESPONSE_V5: Schema
removed: static field Protocol.FIND_COORDINATOR_BROKER_V0: Schema
removed: static field Protocol.FIND_COORDINATOR_REQUEST: Schema[]
removed: static field Protocol.FIND_COORDINATOR_REQUEST_V0: Schema
removed: static field Protocol.FIND_COORDINATOR_REQUEST_V1: Schema
removed: static field Protocol.FIND_COORDINATOR_RESPONSE: Schema[]
removed: static field Protocol.FIND_COORDINATOR_RESPONSE_V0: Schema
removed: static field Protocol.FIND_COORDINATOR_RESPONSE_V1: Schema
removed: static field Protocol.HEARTBEAT_REQUEST: Schema[]
removed: static field Protocol.HEARTBEAT_REQUEST_V0: Schema
removed: static field Protocol.HEARTBEAT_REQUEST_V1: Schema
removed: static field Protocol.HEARTBEAT_RESPONSE: Schema[]
removed: static field Protocol.HEARTBEAT_RESPONSE_V0: Schema
removed: static field Protocol.HEARTBEAT_RESPONSE_V1: Schema
removed: static field Protocol.INIT_PRODUCER_ID_REQUEST: Schema[]
removed: static field Protocol.INIT_PRODUCER_ID_REQUEST_V0: Schema
removed: static field Protocol.INIT_PRODUCER_ID_RESPONSE: Schema[]
removed: static field Protocol.INIT_PRODUCER_ID_RESPONSE_V0: Schema
removed: static field Protocol.JOIN_GROUP_REQUEST: Schema[]
removed: static field Protocol.JOIN_GROUP_REQUEST_PROTOCOL_V0: Schema
removed: static field Protocol.JOIN_GROUP_REQUEST_V0: Schema
removed: static field Protocol.JOIN_GROUP_REQUEST_V1: Schema
removed: static field Protocol.JOIN_GROUP_REQUEST_V2: Schema
removed: static field Protocol.JOIN_GROUP_RESPONSE: Schema[]
removed: static field Protocol.JOIN_GROUP_RESPONSE_MEMBER_V0: Schema
removed: static field Protocol.JOIN_GROUP_RESPONSE_V0: Schema
removed: static field Protocol.JOIN_GROUP_RESPONSE_V1: Schema
removed: static field Protocol.JOIN_GROUP_RESPONSE_V2: Schema
removed: static field Protocol.LEADER_AND_ISR_REQUEST: Schema[]
removed: static field Protocol.LEADER_AND_ISR_REQUEST_LIVE_LEADER_V0: Schema
removed: static field Protocol.LEADER_AND_ISR_REQUEST_PARTITION_STATE_V0: Schema
removed: static field Protocol.LEADER_AND_ISR_REQUEST_V0: Schema
removed: static field Protocol.LEADER_AND_ISR_RESPONSE: Schema[]
removed: static field Protocol.LEADER_AND_ISR_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.LEADER_AND_ISR_RESPONSE_V0: Schema
removed: static field Protocol.LEAVE_GROUP_REQUEST: Schema[]
removed: static field Protocol.LEAVE_GROUP_REQUEST_V0: Schema
removed: static field Protocol.LEAVE_GROUP_REQUEST_V1: Schema
removed: static field Protocol.LEAVE_GROUP_RESPONSE: Schema[]
removed: static field Protocol.LEAVE_GROUP_RESPONSE_V0: Schema
removed: static field Protocol.LEAVE_GROUP_RESPONSE_V1: Schema
removed: static field Protocol.LIST_GROUPS_REQUEST: Schema[]
removed: static field Protocol.LIST_GROUPS_REQUEST_V0: Schema
removed: static field Protocol.LIST_GROUPS_REQUEST_V1: Schema
removed: static field Protocol.LIST_GROUPS_RESPONSE: Schema[]
removed: static field Protocol.LIST_GROUPS_RESPONSE_GROUP_V0: Schema
removed: static field Protocol.LIST_GROUPS_RESPONSE_V0: Schema
removed: static field Protocol.LIST_GROUPS_RESPONSE_V1: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST: Schema[]
removed: static field Protocol.LIST_OFFSET_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_PARTITION_V1: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_TOPIC_V1: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_V0: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_V1: Schema
removed: static field Protocol.LIST_OFFSET_REQUEST_V2: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE: Schema[]
removed: static field Protocol.LIST_OFFSET_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_PARTITION_V1: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_TOPIC_V1: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_V0: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_V1: Schema
removed: static field Protocol.LIST_OFFSET_RESPONSE_V2: Schema
removed: static field Protocol.MATCHING_ACL: Schema
removed: static field Protocol.METADATA_BROKER_V0: Schema
removed: static field Protocol.METADATA_BROKER_V1: Schema
removed: static field Protocol.METADATA_REQUEST: Schema[]
removed: static field Protocol.METADATA_REQUEST_V0: Schema
removed: static field Protocol.METADATA_REQUEST_V1: Schema
removed: static field Protocol.METADATA_REQUEST_V2: Schema
removed: static field Protocol.METADATA_REQUEST_V3: Schema
removed: static field Protocol.METADATA_REQUEST_V4: Schema
removed: static field Protocol.METADATA_RESPONSE: Schema[]
removed: static field Protocol.METADATA_RESPONSE_V0: Schema
removed: static field Protocol.METADATA_RESPONSE_V1: Schema
removed: static field Protocol.METADATA_RESPONSE_V2: Schema
removed: static field Protocol.METADATA_RESPONSE_V3: Schema
removed: static field Protocol.METADATA_RESPONSE_V4: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST: Schema[]
removed: static field Protocol.OFFSET_COMMIT_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_PARTITION_V1: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_PARTITION_V2: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_TOPIC_V1: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_TOPIC_V2: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_V1: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_V2: Schema
removed: static field Protocol.OFFSET_COMMIT_REQUEST_V3: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE: Schema[]
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_V0: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_V1: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_V2: Schema
removed: static field Protocol.OFFSET_COMMIT_RESPONSE_V3: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST: Schema[]
removed: static field Protocol.OFFSET_FETCH_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST_V0: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST_V1: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST_V2: Schema
removed: static field Protocol.OFFSET_FETCH_REQUEST_V3: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE: Schema[]
removed: static field Protocol.OFFSET_FETCH_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE_V0: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE_V1: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE_V2: Schema
removed: static field Protocol.OFFSET_FETCH_RESPONSE_V3: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_REQUEST: Schema[]
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_REQUEST_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_REQUEST_V0: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_RESPONSE: Schema[]
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_RESPONSE_TOPIC_V0: Schema
removed: static field Protocol.OFFSET_FOR_LEADER_EPOCH_RESPONSE_V0: Schema
removed: static field Protocol.PARTITION_METADATA_V0: Schema
removed: static field Protocol.PARTITION_METADATA_V1: Schema
removed: static field Protocol.PARTITION_REPLICA_ASSIGNMENT_ENTRY: Schema
removed: static field Protocol.PRODUCE_REQUEST: Schema[]
removed: static field Protocol.PRODUCE_REQUEST_V0: Schema
removed: static field Protocol.PRODUCE_REQUEST_V1: Schema
removed: static field Protocol.PRODUCE_REQUEST_V2: Schema
removed: static field Protocol.PRODUCE_REQUEST_V3: Schema
removed: static field Protocol.PRODUCE_RESPONSE: Schema[]
removed: static field Protocol.PRODUCE_RESPONSE_V0: Schema
removed: static field Protocol.PRODUCE_RESPONSE_V1: Schema
removed: static field Protocol.PRODUCE_RESPONSE_V2: Schema
removed: static field Protocol.PRODUCE_RESPONSE_V3: Schema
removed: static field Protocol.REQUESTS: Schema[][]
removed: static field Protocol.REQUEST_HEADER: Schema
removed: static field Protocol.RESPONSES: Schema[][]
removed: static field Protocol.RESPONSE_HEADER: Schema
removed: static field Protocol.SASL_HANDSHAKE_REQUEST: Schema[]
removed: static field Protocol.SASL_HANDSHAKE_REQUEST_V0: Schema
removed: static field Protocol.SASL_HANDSHAKE_RESPONSE: Schema[]
removed: static field Protocol.SASL_HANDSHAKE_RESPONSE_V0: Schema
removed: static field Protocol.SINGLE_CREATE_TOPIC_REQUEST_V0: Schema
removed: static field Protocol.SINGLE_CREATE_TOPIC_REQUEST_V1: Schema
removed: static field Protocol.STOP_REPLICA_REQUEST: Schema[]
removed: static field Protocol.STOP_REPLICA_REQUEST_PARTITION_V0: Schema
removed: static field Protocol.STOP_REPLICA_REQUEST_V0: Schema
removed: static field Protocol.STOP_REPLICA_RESPONSE: Schema[]
removed: static field Protocol.STOP_REPLICA_RESPONSE_PARTITION_V0: Schema
removed: static field Protocol.STOP_REPLICA_RESPONSE_V0: Schema
removed: static field Protocol.SYNC_GROUP_REQUEST: Schema[]
removed: static field Protocol.SYNC_GROUP_REQUEST_MEMBER_V0: Schema
removed: static field Protocol.SYNC_GROUP_REQUEST_V0: Schema
removed: static field Protocol.SYNC_GROUP_REQUEST_V1: Schema
removed: static field Protocol.SYNC_GROUP_RESPONSE: Schema[]
removed: static field Protocol.SYNC_GROUP_RESPONSE_V0: Schema
removed: static field Protocol.SYNC_GROUP_RESPONSE_V1: Schema
removed: static field Protocol.TOPIC_ERROR: Schema
removed: static field Protocol.TOPIC_ERROR_CODE: Schema
removed: static field Protocol.TOPIC_METADATA_V0: Schema
removed: static field Protocol.TOPIC_METADATA_V1: Schema
removed: static field Protocol.TOPIC_PRODUCE_DATA_V0: Schema
removed: static field Protocol.TXN_OFFSET_COMMIT_PARTITION_ERROR_RESPONSE_V0: Schema
removed: static field Protocol.TXN_OFFSET_COMMIT_PARTITION_OFFSET_METADATA_REQUEST_V0: Schema
removed: static field Protocol.TXN_OFFSET_COMMIT_REQUEST: Schema[]
removed: static field Protocol.TXN_OFFSET_COMMIT_REQUEST_V0: Schema
removed: static field Protocol.TXN_OFFSET_COMMIT_RESPONSE: Schema[]
removed: static field Protocol.TXN_OFFSET_COMMIT_RESPONSE_V0: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST: Schema[]
removed: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V0: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V1: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V2: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V3: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_END_POINT_V1: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_END_POINT_V2: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_END_POINT_V3: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V0: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V1: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V2: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V3: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_V0: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_V1: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_V2: Schema
removed: static field Protocol.UPDATE_METADATA_REQUEST_V3: Schema
removed: static field Protocol.UPDATE_METADATA_RESPONSE: Schema[]
removed: static field Protocol.UPDATE_METADATA_RESPONSE_V0: Schema
removed: static field Protocol.UPDATE_METADATA_RESPONSE_V1: Schema
removed: static field Protocol.UPDATE_METADATA_RESPONSE_V2: Schema
removed: static field Protocol.UPDATE_METADATA_RESPONSE_V3: Schema
removed: static field Protocol.WRITE_TXN_MARKERS_ENTRY_RESPONSE_V0: Schema
removed: static field Protocol.WRITE_TXN_MARKERS_ENTRY_V0: Schema
removed: static field Protocol.WRITE_TXN_MARKERS_PARTITION_ERROR_RESPONSE_V0: Schema
removed: static field Protocol.WRITE_TXN_MARKERS_REQUEST_V0: Schema
removed: static field Protocol.WRITE_TXN_MARKERS_RESPONSE_V0: Schema
removed: static field Protocol.WRITE_TXN_REQUEST: Schema[]
removed: static field Protocol.WRITE_TXN_RESPONSE: Schema[]
removed: static field SecurityProtocol.PLAINTEXT: SecurityProtocol
removed: static field SecurityProtocol.SASL_PLAINTEXT: SecurityProtocol
removed: static field SecurityProtocol.SASL_SSL: SecurityProtocol
removed: static field SecurityProtocol.SSL: SecurityProtocol
removed: static field SecurityProtocol.TRACE: SecurityProtocol
removed: static method Protocol.apiVersionSupported(short, short): boolean
removed: static method SecurityProtocol.forId(Short): SecurityProtocol
removed: static method SecurityProtocol.forName(String): SecurityProtocol
removed: static method SecurityProtocol.getName(int): String
removed: static method SecurityProtocol.getNames(): List
removed: static method SecurityProtocol.nonTestingValues(): Set
removed: static method SecurityProtocol.valueOf(String): SecurityProtocol
removed: static method SecurityProtocol.values(): SecurityProtocol[]
added: class CommonFields
added: ctor CommonFields()
added: field ApiKeys.requestSchemas: Schema[]
added: field ApiKeys.requiresDelayedAllocation: boolean
added: field ApiKeys.responseSchemas: Schema[]
added: method ApiKeys.isVersionSupported(short): boolean
added: static field ApiKeys.ALTER_REPLICA_LOG_DIRS: ApiKeys
added: static field ApiKeys.CONTROLLED_SHUTDOWN: ApiKeys
added: static field ApiKeys.CREATE_DELEGATION_TOKEN: ApiKeys
added: static field ApiKeys.CREATE_PARTITIONS: ApiKeys
added: static field ApiKeys.DELETE_GROUPS: ApiKeys
added: static field ApiKeys.DESCRIBE_DELEGATION_TOKEN: ApiKeys
added: static field ApiKeys.DESCRIBE_LOG_DIRS: ApiKeys
added: static field ApiKeys.EXPIRE_DELEGATION_TOKEN: ApiKeys
added: static field ApiKeys.RENEW_DELEGATION_TOKEN: ApiKeys
added: static field ApiKeys.SASL_AUTHENTICATE: ApiKeys
added: static field ApiKeys.UPDATE_METADATA: ApiKeys
added: static field CommonFields.ERROR_CODE: Field.Int16
added: static field CommonFields.ERROR_MESSAGE: Field.NullableStr
added: static field CommonFields.GENERATION_ID: Field.Int32
added: static field CommonFields.GROUP_ID: Field.Str
added: static field CommonFields.HOST: Field.Str
added: static field CommonFields.HOST_FILTER: Field.NullableStr
added: static field CommonFields.MEMBER_ID: Field.Str
added: static field CommonFields.NULLABLE_TRANSACTIONAL_ID: Field.NullableStr
added: static field CommonFields.OPERATION: Field.Int8
added: static field CommonFields.PARTITION_ID: Field.Int32
added: static field CommonFields.PERMISSION_TYPE: Field.Int8
added: static field CommonFields.PRINCIPAL: Field.Str
added: static field CommonFields.PRINCIPAL_FILTER: Field.NullableStr
added: static field CommonFields.PRINCIPAL_NAME: Field.Str
added: static field CommonFields.PRINCIPAL_TYPE: Field.Str
added: static field CommonFields.PRODUCER_EPOCH: Field.Int16
added: static field CommonFields.PRODUCER_ID: Field.Int64
added: static field CommonFields.RESOURCE_NAME: Field.Str
added: static field CommonFields.RESOURCE_NAME_FILTER: Field.NullableStr
added: static field CommonFields.RESOURCE_TYPE: Field.Int8
added: static field CommonFields.THROTTLE_TIME_MS: Field.Int32
added: static field CommonFields.TOPIC_NAME: Field.Str
added: static field CommonFields.TRANSACTIONAL_ID: Field.Str
added: static field Errors.DELEGATION_TOKEN_AUTHORIZATION_FAILED: Errors
added: static field Errors.DELEGATION_TOKEN_AUTH_DISABLED: Errors
added: static field Errors.DELEGATION_TOKEN_EXPIRED: Errors
added: static field Errors.DELEGATION_TOKEN_NOT_FOUND: Errors
added: static field Errors.DELEGATION_TOKEN_OWNER_MISMATCH: Errors
added: static field Errors.DELEGATION_TOKEN_REQUEST_NOT_ALLOWED: Errors
added: static field Errors.FETCH_SESSION_ID_NOT_FOUND: Errors
added: static field Errors.GROUP_ID_NOT_FOUND: Errors
added: static field Errors.INVALID_FETCH_SESSION_EPOCH: Errors
added: static field Errors.INVALID_PRINCIPAL_TYPE: Errors
added: static field Errors.KAFKA_STORAGE_ERROR: Errors
added: static field Errors.LOG_DIR_NOT_FOUND: Errors
added: static field Errors.NON_EMPTY_GROUP: Errors
added: static field Errors.REASSIGNMENT_IN_PROGRESS: Errors
added: static field Errors.SASL_AUTHENTICATION_FAILED: Errors
added: static field Errors.UNKNOWN_PRODUCER_ID: Errors
added: static field Errors.UNKNOWN_SERVER_ERROR: Errors

removed: ctor Field(int, String, Type, String, Object, Schema)
removed: field Field.doc: String
removed: method Field.schema(): Schema
removed: method Field.type(): Type
removed: static field Field.NO_DEFAULT: Object
changed: ctor Field(int, String, Type, String, Object) → ctor Field(String, Type, String, boolean, Object)
changed: method Schema.fields(): Field[] → method Schema.fields(): BoundField[]
changed: method Schema.get(String): Field → method Schema.get(String): BoundField
changed: method Schema.get(int): Field → method Schema.get(int): BoundField
changed: method Struct.get(Field): Object → method Struct.get(BoundField): Object
changed: method Struct.getArray(Field): Object[] → method Struct.getArray(BoundField): Object[]
changed: method Struct.getBoolean(Field): Boolean → method Struct.getBoolean(BoundField): Boolean
changed: method Struct.getByte(Field): Byte → method Struct.getByte(BoundField): Byte
changed: method Struct.getBytes(Field): ByteBuffer → method Struct.getBytes(BoundField): ByteBuffer
changed: method Struct.getInt(Field): Integer → method Struct.getInt(BoundField): Integer
changed: method Struct.getLong(Field): Long → method Struct.getLong(BoundField): Long
changed: method Struct.getShort(Field): Short → method Struct.getShort(BoundField): Short
changed: method Struct.getString(Field): String → method Struct.getString(BoundField): String
changed: method Struct.getStruct(Field): Struct → method Struct.getStruct(BoundField): Struct
changed: method Struct.instance(Field): Struct → method Struct.instance(BoundField): Struct
changed: method Struct.set(Field, Object): Struct → method Struct.set(BoundField, Object): Struct
added: class BoundField
added: ctor BoundField(Field, Schema, int)
added: ctor Field.Int16(String, String)
added: ctor Field.Int32(String, String)
added: ctor Field.Int32(String, String, int)
added: ctor Field.Int64(String, String)
added: ctor Field.Int64(String, String, long)
added: ctor Field.Int8(String, String)
added: ctor Field.NullableStr(String, String)
added: ctor Field.Str(String, String)
added: ctor Schema.Visitor()
added: field BoundField.def: Field
added: field Field.docString: String
added: field Field.hasDefaultValue: boolean
added: method BoundField.toString(): String
added: method Schema.Visitor.visit(ArrayOf): void
added: method Schema.Visitor.visit(Schema): void
added: method Schema.Visitor.visit(Type): void
added: method Schema.walk(Schema.Visitor): void
added: method Struct.get(Field.Int16): Short
added: method Struct.get(Field.Int32): Integer
added: method Struct.get(Field.Int64): Long
added: method Struct.get(Field.Int8): Byte
added: method Struct.get(Field.NullableStr): String
added: method Struct.get(Field.Str): String
added: method Struct.getOrElse(Field.Int16, short): Short
added: method Struct.getOrElse(Field.Int32, int): Integer
added: method Struct.getOrElse(Field.Int64, long): Long
added: method Struct.getOrElse(Field.NullableStr, String): String
added: method Struct.getOrElse(Field.Str, String): String
added: method Struct.hasField(Field): boolean
added: method Struct.set(Field.Int16, short): Struct
added: method Struct.set(Field.Int32, int): Struct
added: method Struct.set(Field.Int64, long): Struct
added: method Struct.set(Field.Int8, byte): Struct
added: method Struct.set(Field.NullableStr, String): Struct
added: method Struct.set(Field.Str, String): Struct
added: method Struct.setIfExists(Field, Object): Struct
added: method Struct.setIfExists(String, Object): Struct
added: static abstract class Schema.Visitor
added: static class Field.Int16 extends Field
added: static class Field.Int32 extends Field
added: static class Field.Int64 extends Field
added: static class Field.Int8 extends Field
added: static class Field.NullableStr extends Field
added: static class Field.Str extends Field

removed: method FileRecords.delete(): boolean
removed: method MemoryRecordsBuilder.sizeInBytes(): int
changed: final class KafkaLZ4BlockOutputStream extends FilterOutputStream → final class KafkaLZ4BlockOutputStream extends OutputStream
changed: method AbstractRecords.downConvert(Iterable, byte, long): MemoryRecords → method AbstractRecords.downConvert(Iterable, byte, long, Time): ConvertedRecords
changed: method FileRecords.downConvert(byte, long): Records → method FileRecords.downConvert(byte, long, Time): ConvertedRecords
changed: method MemoryRecords.downConvert(byte, long): MemoryRecords → method MemoryRecords.downConvert(byte, long, Time): ConvertedRecords
changed: method Records.downConvert(byte, long): Records → method Records.downConvert(byte, long, Time): ConvertedRecords
added: class ConvertedRecords
added: class RecordsProcessingStats
added: ctor ConvertedRecords(Records, RecordsProcessingStats)
added: ctor RecordsProcessingStats(long, int, long)
added: enum RecordFormat
added: field RecordFormat.value: byte
added: method ConvertedRecords.records(): Records
added: method ConvertedRecords.recordsProcessingStats(): RecordsProcessingStats
added: method FileRecords.closeHandlers(): void
added: method FileRecords.deleteIfExists(): boolean
added: method MemoryRecordsBuilder.baseSequence(): int
added: method MemoryRecordsBuilder.estimatedSizeInBytes(): int
added: method MemoryRecordsBuilder.numRecords(): int
added: method MemoryRecordsBuilder.reopenAndRewriteProducerState(long, short, int, boolean): void
added: method MemoryRecordsBuilder.uncompressedBytesWritten(): int
added: method RecordsProcessingStats.conversionTimeNanos(): long
added: method RecordsProcessingStats.numRecordsConverted(): int
added: method RecordsProcessingStats.temporaryMemoryBytes(): long
added: method RecordsProcessingStats.toString(): String
added: static field DefaultRecordBatch.LAST_OFFSET_DELTA_OFFSET: int
added: static field DefaultRecordBatch.RECORDS_COUNT_OFFSET: int
added: static field RecordFormat.V0: RecordFormat
added: static field RecordFormat.V1: RecordFormat
added: static field RecordFormat.V2: RecordFormat
added: static field RecordsProcessingStats.EMPTY: RecordsProcessingStats
added: static method AbstractRecords.recordBatchHeaderSizeInBytes(byte, CompressionType): int
added: static method RecordFormat.current(): RecordFormat
added: static method RecordFormat.lookup(byte): RecordFormat
added: static method RecordFormat.valueOf(String): RecordFormat
added: static method RecordFormat.values(): RecordFormat[]

removed: class PartitionState
removed: ctor PartitionState(int, int, int, List, int, List)
removed: ctor ProduceRequest.Builder(byte, short, int, Map)
removed: ctor ProduceRequest.Builder(byte, short, int, Map, String)
removed: field PartitionState.controllerEpoch: int
removed: field PartitionState.isr: List
removed: field PartitionState.leader: int
removed: field PartitionState.leaderEpoch: int
removed: field PartitionState.replicas: List
removed: field PartitionState.zkVersion: int
removed: method AbstractRequest.Builder.desiredOrLatestVersion(): short
removed: method AbstractRequest.Builder.desiredVersion(): Short
removed: method AbstractResponse.toSend(String, short, ResponseHeader): Send
removed: method DescribeConfigsResponse.ConfigEntry.isDefault(): boolean
removed: method FetchResponse.toSend(Struct, int, String, RequestHeader): Send
removed: method PartitionState.toString(): String
removed: static field AbstractResponse.THROTTLE_TIME_KEY_NAME: String
removed: static field ApiVersionsResponse.API_KEY_NAME: String
removed: static field ApiVersionsResponse.API_VERSIONS_KEY_NAME: String
removed: static field ApiVersionsResponse.API_VERSIONS_RESPONSE: ApiVersionsResponse
removed: static field ApiVersionsResponse.ERROR_CODE_KEY_NAME: String
removed: static field ApiVersionsResponse.MAX_VERSION_KEY_NAME: String
removed: static field ApiVersionsResponse.MIN_VERSION_KEY_NAME: String
removed: static field ListGroupsResponse.ERROR_CODE_KEY_NAME: String
removed: static field ListGroupsResponse.GROUPS_KEY_NAME: String
removed: static field ListGroupsResponse.GROUP_ID_KEY_NAME: String
removed: static field ListGroupsResponse.PROTOCOL_TYPE_KEY_NAME: String
removed: static field OffsetsForLeaderEpochRequest.LEADER_EPOCH: String
removed: static field OffsetsForLeaderEpochRequest.PARTITIONS: String
removed: static field OffsetsForLeaderEpochRequest.PARTITION_ID: String
removed: static field OffsetsForLeaderEpochRequest.TOPIC: String
removed: static field OffsetsForLeaderEpochRequest.TOPICS: String
removed: static field OffsetsForLeaderEpochResponse.END_OFFSET: String
removed: static field OffsetsForLeaderEpochResponse.ERROR_CODE: String
removed: static field OffsetsForLeaderEpochResponse.PARTITIONS: String
removed: static field OffsetsForLeaderEpochResponse.PARTITION_ID: String
removed: static field OffsetsForLeaderEpochResponse.TOPIC: String
removed: static field OffsetsForLeaderEpochResponse.TOPICS: String
removed: static field SaslHandshakeRequest.MECHANISM_KEY_NAME: String
removed: static field SyncGroupRequest.GENERATION_ID_KEY_NAME: String
removed: static field SyncGroupRequest.GROUP_ASSIGNMENT_KEY_NAME: String
removed: static field SyncGroupRequest.GROUP_ID_KEY_NAME: String
removed: static field SyncGroupRequest.MEMBER_ASSIGNMENT_KEY_NAME: String
removed: static field SyncGroupRequest.MEMBER_ID_KEY_NAME: String
removed: static field SyncGroupResponse.ERROR_CODE_KEY_NAME: String
removed: static field SyncGroupResponse.MEMBER_ASSIGNMENT_KEY_NAME: String
removed: static method AbstractRequest.getRequest(int, short, ByteBuffer): RequestAndSize
removed: static method AbstractResponse.getResponse(ApiKeys, Struct): AbstractResponse
removed: static method ApiVersionsResponse.unsupportedVersionSend(String, RequestHeader): Send
removed: static method FetchRequest.Builder.forConsumer(int, int, LinkedHashMap, IsolationLevel): FetchRequest.Builder
removed: static method ListGroupsResponse.fromError(Errors): ListGroupsResponse
removed: static method ListGroupsResponse.fromError(int, Errors): ListGroupsResponse
changed: ctor AbstractRequest.Builder(ApiKeys, Short) → ctor AbstractRequest.Builder(ApiKeys, short)
changed: ctor ControlledShutdownRequest.Builder(int) → ctor ControlledShutdownRequest.Builder(int, short)
changed: ctor DescribeConfigsRequest(short, Map) → ctor DescribeConfigsRequest(short, Map, boolean)
changed: ctor DescribeConfigsResponse.ConfigEntry(String, String, boolean, boolean, boolean) → ctor DescribeConfigsResponse.ConfigEntry(String, String, DescribeConfigsResponse.ConfigSource, boolean, boolean, Collection)
changed: ctor FetchResponse(LinkedHashMap, int) → ctor FetchResponse(Errors, LinkedHashMap, int, int)
changed: ctor LeaderAndIsrRequest.Builder(int, int, Map, Set) → ctor LeaderAndIsrRequest.Builder(short, int, int, Map, Set)
changed: ctor MetadataResponse.PartitionMetadata(Errors, int, Node, List, List) → ctor MetadataResponse.PartitionMetadata(Errors, int, Node, List, List, List)
changed: ctor ProduceResponse.PartitionResponse(Errors, long, long) → ctor ProduceResponse.PartitionResponse(Errors, long, long, long)
changed: ctor RequestHeader(short, short, String, int) → ctor RequestHeader(ApiKeys, short, String, int)
changed: method AbstractResponse.toSend(String, RequestHeader): Send → method AbstractResponse.toSend(String, ResponseHeader, short): Send
changed: method ApiVersionsRequest.getErrorResponse(int, Throwable): AbstractResponse → method ApiVersionsRequest.getErrorResponse(int, Throwable): ApiVersionsResponse
changed: method FetchRequest.Builder.fetchData(): LinkedHashMap → method FetchRequest.Builder.fetchData(): Map
changed: method FetchResponse.toSend(String, RequestHeader): Send → method FetchResponse.toSend(String, ResponseHeader, short): Send
changed: method LeaderAndIsrRequest.getErrorResponse(int, Throwable): AbstractResponse → method LeaderAndIsrRequest.getErrorResponse(int, Throwable): LeaderAndIsrResponse
changed: method ListGroupsRequest.getErrorResponse(int, Throwable): AbstractResponse → method ListGroupsRequest.getErrorResponse(int, Throwable): ListGroupsResponse
changed: method RequestHeader.apiKey(): short → method RequestHeader.apiKey(): ApiKeys
changed: method StopReplicaRequest.getErrorResponse(int, Throwable): AbstractResponse → method StopReplicaRequest.getErrorResponse(int, Throwable): StopReplicaResponse
changed: static method FetchRequest.Builder.forConsumer(int, int, LinkedHashMap): FetchRequest.Builder → static method FetchRequest.Builder.forConsumer(int, int, Map): FetchRequest.Builder
changed: static method FetchRequest.Builder.forReplica(short, int, int, int, LinkedHashMap): FetchRequest.Builder → static method FetchRequest.Builder.forReplica(short, int, int, int, Map): FetchRequest.Builder
changed: static method FetchResponse.sizeOf(short, LinkedHashMap): int → static method FetchResponse.sizeOf(short, Iterator): int
added: class AlterReplicaLogDirsRequest extends AbstractRequest
added: class AlterReplicaLogDirsResponse extends AbstractResponse
added: class BasePartitionState
added: class CreateDelegationTokenRequest extends AbstractRequest
added: class CreateDelegationTokenResponse extends AbstractResponse
added: class CreatePartitionsRequest extends AbstractRequest
added: class CreatePartitionsResponse extends AbstractResponse
added: class DeleteGroupsRequest extends AbstractRequest
added: class DeleteGroupsResponse extends AbstractResponse
added: class DescribeDelegationTokenRequest extends AbstractRequest
added: class DescribeDelegationTokenResponse extends AbstractResponse
added: class DescribeLogDirsRequest extends AbstractRequest
added: class DescribeLogDirsResponse extends AbstractResponse
added: class ExpireDelegationTokenRequest extends AbstractRequest
added: class ExpireDelegationTokenResponse extends AbstractResponse
added: class FetchMetadata
added: class RenewDelegationTokenRequest extends AbstractRequest
added: class RenewDelegationTokenResponse extends AbstractResponse
added: class RequestContext
added: class SaslAuthenticateRequest extends AbstractRequest
added: class SaslAuthenticateResponse extends AbstractResponse
added: ctor AbstractRequest.Builder(ApiKeys, short, short)
added: ctor AlterReplicaLogDirsRequest(Map, short)
added: ctor AlterReplicaLogDirsRequest(Struct, short)
added: ctor AlterReplicaLogDirsRequest.Builder(Map)
added: ctor AlterReplicaLogDirsResponse(Struct)
added: ctor AlterReplicaLogDirsResponse(int, Map)
added: ctor ApiVersionsRequest(short, Short)
added: ctor CreateDelegationTokenRequest(Struct, short)
added: ctor CreateDelegationTokenRequest.Builder(List, long)
added: ctor CreateDelegationTokenResponse(Struct)
added: ctor CreateDelegationTokenResponse(int, Errors, KafkaPrincipal)
added: ctor CreateDelegationTokenResponse(int, Errors, KafkaPrincipal, long, long, long, String, ByteBuffer)
added: ctor CreatePartitionsRequest(Struct, short)
added: ctor CreatePartitionsRequest.Builder(Map, int, boolean)
added: ctor CreatePartitionsResponse(Struct)
added: ctor CreatePartitionsResponse(int, Map)
added: ctor DeleteGroupsRequest(Struct, short)
added: ctor DeleteGroupsRequest.Builder(Set)
added: ctor DeleteGroupsResponse(Map)
added: ctor DeleteGroupsResponse(Struct)
added: ctor DeleteGroupsResponse(int, Map)
added: ctor DescribeConfigsResponse.ConfigSynonym(String, String, DescribeConfigsResponse.ConfigSource)
added: ctor DescribeDelegationTokenRequest(Struct, short)
added: ctor DescribeDelegationTokenRequest.Builder(List)
added: ctor DescribeDelegationTokenResponse(Struct)
added: ctor DescribeDelegationTokenResponse(int, Errors)
added: ctor DescribeDelegationTokenResponse(int, Errors, List)
added: ctor DescribeLogDirsRequest(Set, short)
added: ctor DescribeLogDirsRequest(Struct, short)
added: ctor DescribeLogDirsRequest.Builder(Set)
added: ctor DescribeLogDirsResponse(Struct)
added: ctor DescribeLogDirsResponse(int, Map)
added: ctor DescribeLogDirsResponse.LogDirInfo(Errors, Map)
added: ctor DescribeLogDirsResponse.ReplicaInfo(long, long, boolean)
added: ctor ExpireDelegationTokenRequest(Struct, short)
added: ctor ExpireDelegationTokenRequest.Builder(ByteBuffer, long)
added: ctor ExpireDelegationTokenResponse(Struct)
added: ctor ExpireDelegationTokenResponse(int, Errors)
added: ctor ExpireDelegationTokenResponse(int, Errors, long)
added: ctor FetchMetadata(int, int)
added: ctor FetchRequest.Builder(short, short, int, int, int, Map)
added: ctor LeaderAndIsrRequest.PartitionState(int, int, int, List, int, List, boolean)
added: ctor RenewDelegationTokenRequest(Struct, short)
added: ctor RenewDelegationTokenRequest.Builder(ByteBuffer, long)
added: ctor RenewDelegationTokenResponse(Struct)
added: ctor RenewDelegationTokenResponse(int, Errors)
added: ctor RenewDelegationTokenResponse(int, Errors, long)
added: ctor RequestContext(RequestHeader, String, InetAddress, KafkaPrincipal, ListenerName, SecurityProtocol)
added: ctor SaslAuthenticateRequest(ByteBuffer)
added: ctor SaslAuthenticateRequest(ByteBuffer, short)
added: ctor SaslAuthenticateRequest(Struct, short)
added: ctor SaslAuthenticateRequest.Builder(ByteBuffer)
added: ctor SaslAuthenticateResponse(Errors, String)
added: ctor SaslAuthenticateResponse(Errors, String, ByteBuffer)
added: ctor SaslAuthenticateResponse(Struct)
added: ctor SaslHandshakeRequest(String, short)
added: ctor UpdateMetadataRequest.PartitionState(int, int, int, List, int, List, List)
added: enum DescribeConfigsResponse.ConfigSource
added: field BasePartitionState.controllerEpoch: int
added: field BasePartitionState.isr: List
added: field BasePartitionState.leader: int
added: field BasePartitionState.leaderEpoch: int
added: field BasePartitionState.replicas: List
added: field BasePartitionState.zkVersion: int
added: field DescribeLogDirsResponse.LogDirInfo.error: Errors
added: field DescribeLogDirsResponse.LogDirInfo.replicaInfos: Map
added: field DescribeLogDirsResponse.ReplicaInfo.isFuture: boolean
added: field DescribeLogDirsResponse.ReplicaInfo.offsetLag: long
added: field DescribeLogDirsResponse.ReplicaInfo.size: long
added: field LeaderAndIsrRequest.PartitionState.basePartitionState: BasePartitionState
added: field LeaderAndIsrRequest.PartitionState.isNew: boolean
added: field ProduceResponse.PartitionResponse.logStartOffset: long
added: field RequestContext.clientAddress: InetAddress
added: field RequestContext.connectionId: String
added: field RequestContext.header: RequestHeader
added: field RequestContext.listenerName: ListenerName
added: field RequestContext.principal: KafkaPrincipal
added: field RequestContext.securityProtocol: SecurityProtocol
added: field UpdateMetadataRequest.PartitionState.basePartitionState: BasePartitionState
added: field UpdateMetadataRequest.PartitionState.offlineReplicas: List
added: method AbstractRequest.Builder.latestAllowedVersion(): short
added: method AbstractRequest.Builder.oldestAllowedVersion(): short
added: method AbstractRequest.errorCounts(Throwable): Map
added: method AbstractResponse.apiErrorCounts(Map): Map
added: method AbstractResponse.errorCounts(): Map
added: method AbstractResponse.errorCounts(Errors): Map
added: method AbstractResponse.errorCounts(Map): Map
added: method AbstractResponse.updateErrorCounts(Map, Errors): void
added: method AddOffsetsToTxnResponse.errorCounts(): Map
added: method AddPartitionsToTxnResponse.errorCounts(): Map
added: method AlterConfigsResponse.errorCounts(): Map
added: method AlterReplicaLogDirsRequest.Builder.build(short): AlterReplicaLogDirsRequest
added: method AlterReplicaLogDirsRequest.Builder.toString(): String
added: method AlterReplicaLogDirsRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method AlterReplicaLogDirsRequest.partitionDirs(): Map
added: method AlterReplicaLogDirsRequest.toStruct(): Struct
added: method AlterReplicaLogDirsResponse.errorCounts(): Map
added: method AlterReplicaLogDirsResponse.responses(): Map
added: method AlterReplicaLogDirsResponse.throttleTimeMs(): int
added: method AlterReplicaLogDirsResponse.toStruct(short): Struct
added: method ApiVersionsRequest.hasUnsupportedRequestVersion(): boolean
added: method ApiVersionsResponse.errorCounts(): Map
added: method ControlledShutdownResponse.errorCounts(): Map
added: method CreateAclsResponse.errorCounts(): Map
added: method CreateDelegationTokenRequest.Builder.build(short): CreateDelegationTokenRequest
added: method CreateDelegationTokenRequest.Builder.toString(): String
added: method CreateDelegationTokenRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method CreateDelegationTokenRequest.maxLifeTime(): long
added: method CreateDelegationTokenRequest.renewers(): List
added: method CreateDelegationTokenRequest.toStruct(): Struct
added: method CreateDelegationTokenResponse.error(): Errors
added: method CreateDelegationTokenResponse.errorCounts(): Map
added: method CreateDelegationTokenResponse.expiryTimestamp(): long
added: method CreateDelegationTokenResponse.hasError(): boolean
added: method CreateDelegationTokenResponse.hmacBytes(): byte[]
added: method CreateDelegationTokenResponse.issueTimestamp(): long
added: method CreateDelegationTokenResponse.maxTimestamp(): long
added: method CreateDelegationTokenResponse.owner(): KafkaPrincipal
added: method CreateDelegationTokenResponse.throttleTimeMs(): int
added: method CreateDelegationTokenResponse.toStruct(short): Struct
added: method CreateDelegationTokenResponse.tokenId(): String
added: method CreatePartitionsRequest.Builder.build(short): CreatePartitionsRequest
added: method CreatePartitionsRequest.Builder.toString(): String
added: method CreatePartitionsRequest.duplicates(): Set
added: method CreatePartitionsRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method CreatePartitionsRequest.newPartitions(): Map
added: method CreatePartitionsRequest.timeout(): int
added: method CreatePartitionsRequest.toStruct(): Struct
added: method CreatePartitionsRequest.validateOnly(): boolean
added: method CreatePartitionsResponse.errorCounts(): Map
added: method CreatePartitionsResponse.errors(): Map
added: method CreatePartitionsResponse.throttleTimeMs(): int
added: method CreatePartitionsResponse.toStruct(short): Struct
added: method CreateTopicsResponse.errorCounts(): Map
added: method DeleteAclsResponse.errorCounts(): Map
added: method DeleteGroupsRequest.Builder.build(short): DeleteGroupsRequest
added: method DeleteGroupsRequest.Builder.toString(): String
added: method DeleteGroupsRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method DeleteGroupsRequest.groups(): Set
added: method DeleteGroupsRequest.toStruct(): Struct
added: method DeleteGroupsResponse.errorCounts(): Map
added: method DeleteGroupsResponse.errors(): Map
added: method DeleteGroupsResponse.get(String): Errors
added: method DeleteGroupsResponse.hasError(String): boolean
added: method DeleteGroupsResponse.throttleTimeMs(): int
added: method DeleteGroupsResponse.toStruct(short): Struct
added: method DeleteRecordsResponse.errorCounts(): Map
added: method DeleteTopicsResponse.errorCounts(): Map
added: method DescribeAclsResponse.errorCounts(): Map
added: method DescribeConfigsRequest.Builder.includeSynonyms(boolean): DescribeConfigsRequest.Builder
added: method DescribeConfigsRequest.includeSynonyms(): boolean
added: method DescribeConfigsResponse.ConfigEntry.source(): DescribeConfigsResponse.ConfigSource
added: method DescribeConfigsResponse.ConfigEntry.synonyms(): Collection
added: method DescribeConfigsResponse.ConfigSynonym.name(): String
added: method DescribeConfigsResponse.ConfigSynonym.source(): DescribeConfigsResponse.ConfigSource
added: method DescribeConfigsResponse.ConfigSynonym.value(): String
added: method DescribeConfigsResponse.errorCounts(): Map
added: method DescribeDelegationTokenRequest.Builder.build(short): DescribeDelegationTokenRequest
added: method DescribeDelegationTokenRequest.Builder.toString(): String
added: method DescribeDelegationTokenRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method DescribeDelegationTokenRequest.owners(): List
added: method DescribeDelegationTokenRequest.ownersListEmpty(): boolean
added: method DescribeDelegationTokenRequest.toStruct(): Struct
added: method DescribeDelegationTokenResponse.error(): Errors
added: method DescribeDelegationTokenResponse.errorCounts(): Map
added: method DescribeDelegationTokenResponse.throttleTimeMs(): int
added: method DescribeDelegationTokenResponse.toStruct(short): Struct
added: method DescribeDelegationTokenResponse.tokens(): List
added: method DescribeGroupsResponse.errorCounts(): Map
added: method DescribeLogDirsRequest.Builder.build(short): DescribeLogDirsRequest
added: method DescribeLogDirsRequest.Builder.toString(): String
added: method DescribeLogDirsRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method DescribeLogDirsRequest.isAllTopicPartitions(): boolean
added: method DescribeLogDirsRequest.toStruct(): Struct
added: method DescribeLogDirsRequest.topicPartitions(): Set
added: method DescribeLogDirsResponse.LogDirInfo.toString(): String
added: method DescribeLogDirsResponse.ReplicaInfo.toString(): String
added: method DescribeLogDirsResponse.errorCounts(): Map
added: method DescribeLogDirsResponse.logDirInfos(): Map
added: method DescribeLogDirsResponse.throttleTimeMs(): int
added: method DescribeLogDirsResponse.toStruct(short): Struct
added: method EndTxnResponse.errorCounts(): Map
added: method ExpireDelegationTokenRequest.Builder.build(short): ExpireDelegationTokenRequest
added: method ExpireDelegationTokenRequest.Builder.toString(): String
added: method ExpireDelegationTokenRequest.expiryTimePeriod(): long
added: method ExpireDelegationTokenRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method ExpireDelegationTokenRequest.hmac(): ByteBuffer
added: method ExpireDelegationTokenRequest.toStruct(): Struct
added: method ExpireDelegationTokenResponse.error(): Errors
added: method ExpireDelegationTokenResponse.errorCounts(): Map
added: method ExpireDelegationTokenResponse.expiryTimestamp(): long
added: method ExpireDelegationTokenResponse.throttleTimeMs(): int
added: method ExpireDelegationTokenResponse.toStruct(short): Struct
added: method FetchMetadata.epoch(): int
added: method FetchMetadata.equals(Object): boolean
added: method FetchMetadata.hashCode(): int
added: method FetchMetadata.isFull(): boolean
added: method FetchMetadata.nextCloseExisting(): FetchMetadata
added: method FetchMetadata.nextIncremental(): FetchMetadata
added: method FetchMetadata.sessionId(): int
added: method FetchMetadata.toString(): String
added: method FetchRequest.Builder.isolationLevel(IsolationLevel): FetchRequest.Builder
added: method FetchRequest.Builder.metadata(FetchMetadata): FetchRequest.Builder
added: method FetchRequest.Builder.toForget(): List
added: method FetchRequest.Builder.toForget(List): FetchRequest.Builder
added: method FetchRequest.PartitionData.equals(Object): boolean
added: method FetchRequest.PartitionData.hashCode(): int
added: method FetchRequest.metadata(): FetchMetadata
added: method FetchRequest.toForget(): List
added: method FetchResponse.error(): Errors
added: method FetchResponse.errorCounts(): Map
added: method FetchResponse.sessionId(): int
added: method FindCoordinatorResponse.errorCounts(): Map
added: method HeartbeatResponse.errorCounts(): Map
added: method InitProducerIdResponse.errorCounts(): Map
added: method JoinGroupResponse.errorCounts(): Map
added: method JoinGroupResponse.toString(): String
added: method LeaderAndIsrRequest.PartitionState.toString(): String
added: method LeaderAndIsrResponse.errorCounts(): Map
added: method LeaderAndIsrResponse.toString(): String
added: method LeaveGroupResponse.errorCounts(): Map
added: method ListGroupsResponse.errorCounts(): Map
added: method ListOffsetResponse.errorCounts(): Map
added: method ListOffsetResponse.toString(): String
added: method MetadataResponse.PartitionMetadata.leaderId(): int
added: method MetadataResponse.PartitionMetadata.offlineReplicas(): List
added: method MetadataResponse.TopicMetadata.toString(): String
added: method MetadataResponse.errorCounts(): Map
added: method OffsetCommitResponse.errorCounts(): Map
added: method OffsetFetchResponse.errorCounts(): Map
added: method OffsetsForLeaderEpochResponse.errorCounts(): Map
added: method ProduceRequest.errorCounts(Throwable): Map
added: method ProduceResponse.errorCounts(): Map
added: method RenewDelegationTokenRequest.Builder.build(short): RenewDelegationTokenRequest
added: method RenewDelegationTokenRequest.Builder.toString(): String
added: method RenewDelegationTokenRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method RenewDelegationTokenRequest.hmac(): ByteBuffer
added: method RenewDelegationTokenRequest.renewTimePeriod(): long
added: method RenewDelegationTokenRequest.toStruct(): Struct
added: method RenewDelegationTokenResponse.error(): Errors
added: method RenewDelegationTokenResponse.errorCounts(): Map
added: method RenewDelegationTokenResponse.expiryTimestamp(): long
added: method RenewDelegationTokenResponse.throttleTimeMs(): int
added: method RenewDelegationTokenResponse.toStruct(short): Struct
added: method RequestContext.apiVersion(): short
added: method RequestContext.buildResponse(AbstractResponse): Send
added: method RequestContext.parseRequest(ByteBuffer): RequestAndSize
added: method RequestHeader.equals(Object): boolean
added: method RequestHeader.hashCode(): int
added: method SaslAuthenticateRequest.Builder.build(short): SaslAuthenticateRequest
added: method SaslAuthenticateRequest.Builder.toString(): String
added: method SaslAuthenticateRequest.getErrorResponse(int, Throwable): AbstractResponse
added: method SaslAuthenticateRequest.saslAuthBytes(): ByteBuffer
added: method SaslAuthenticateRequest.toStruct(): Struct
added: method SaslAuthenticateResponse.error(): Errors
added: method SaslAuthenticateResponse.errorCounts(): Map
added: method SaslAuthenticateResponse.errorMessage(): String
added: method SaslAuthenticateResponse.saslAuthBytes(): ByteBuffer
added: method SaslAuthenticateResponse.toStruct(short): Struct
added: method SaslHandshakeResponse.errorCounts(): Map
added: method StopReplicaResponse.errorCounts(): Map
added: method StopReplicaResponse.toString(): String
added: method SyncGroupResponse.errorCounts(): Map
added: method TxnOffsetCommitResponse.errorCounts(): Map
added: method UpdateMetadataRequest.PartitionState.toString(): String
added: method UpdateMetadataResponse.errorCounts(): Map
added: method WriteTxnMarkersResponse.errorCounts(): Map
added: static class AlterReplicaLogDirsRequest.Builder extends AbstractRequest.Builder
added: static class CreateDelegationTokenRequest.Builder extends AbstractRequest.Builder
added: static class CreatePartitionsRequest.Builder extends AbstractRequest.Builder
added: static class DeleteGroupsRequest.Builder extends AbstractRequest.Builder
added: static class DescribeConfigsResponse.ConfigSynonym
added: static class DescribeDelegationTokenRequest.Builder extends AbstractRequest.Builder
added: static class DescribeLogDirsRequest.Builder extends AbstractRequest.Builder
added: static class DescribeLogDirsResponse.LogDirInfo
added: static class DescribeLogDirsResponse.ReplicaInfo
added: static class ExpireDelegationTokenRequest.Builder extends AbstractRequest.Builder
added: static class RenewDelegationTokenRequest.Builder extends AbstractRequest.Builder
added: static class SaslAuthenticateRequest.Builder extends AbstractRequest.Builder
added: static field DescribeConfigsResponse.ConfigSource.DEFAULT_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeConfigsResponse.ConfigSource.DYNAMIC_BROKER_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeConfigsResponse.ConfigSource.DYNAMIC_DEFAULT_BROKER_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeConfigsResponse.ConfigSource.STATIC_BROKER_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeConfigsResponse.ConfigSource.TOPIC_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeConfigsResponse.ConfigSource.UNKNOWN_CONFIG: DescribeConfigsResponse.ConfigSource
added: static field DescribeDelegationTokenRequest.TOKEN_DESCRIBE_REQUEST_V0: Schema
added: static field DescribeLogDirsResponse.INVALID_OFFSET_LAG: long
added: static field FetchMetadata.FINAL_EPOCH: int
added: static field FetchMetadata.INITIAL: FetchMetadata
added: static field FetchMetadata.INITIAL_EPOCH: int
added: static field FetchMetadata.INVALID_SESSION_ID: int
added: static field FetchMetadata.LEGACY: FetchMetadata
added: static field FetchMetadata.log: Logger
added: static field FetchRequest.EPOCH: Field.Int32
added: static field FetchRequest.SESSION_ID: Field.Int32
added: static field FetchResponse.SESSION_ID: Field.Int32
added: static field OffsetFetchResponse.UNAUTHORIZED_PARTITION: OffsetFetchResponse.PartitionData
added: static field ProduceResponse.PRODUCE_RESPONSE_V5: Schema
added: static field RenewDelegationTokenRequest.TOKEN_RENEW_REQUEST_V0: Schema
added: static field RequestHeader.SCHEMA: Schema
added: static field ResponseHeader.SCHEMA: Schema
added: static final class LeaderAndIsrRequest.PartitionState
added: static final class UpdateMetadataRequest.PartitionState
added: static method AbstractRequest.parseRequest(ApiKeys, short, Struct): AbstractRequest
added: static method AbstractResponse.parseResponse(ApiKeys, Struct): AbstractResponse
added: static method AddOffsetsToTxnRequest.schemaVersions(): Schema[]
added: static method AddOffsetsToTxnResponse.schemaVersions(): Schema[]
added: static method AddPartitionsToTxnRequest.schemaVersions(): Schema[]
added: static method AddPartitionsToTxnResponse.schemaVersions(): Schema[]
added: static method AlterConfigsRequest.schemaVersions(): Schema[]
added: static method AlterConfigsResponse.schemaVersions(): Schema[]
added: static method AlterReplicaLogDirsRequest.parse(ByteBuffer, short): AlterReplicaLogDirsRequest
added: static method AlterReplicaLogDirsRequest.schemaVersions(): Schema[]
added: static method AlterReplicaLogDirsResponse.parse(ByteBuffer, short): AlterReplicaLogDirsResponse
added: static method AlterReplicaLogDirsResponse.schemaVersions(): Schema[]
added: static method ApiVersionsRequest.schemaVersions(): Schema[]
added: static method ApiVersionsResponse.defaultApiVersionsResponse(): ApiVersionsResponse
added: static method ApiVersionsResponse.schemaVersions(): Schema[]
added: static method ControlledShutdownRequest.schemaVersions(): Schema[]
added: static method ControlledShutdownResponse.schemaVersions(): Schema[]
added: static method CreateAclsRequest.schemaVersions(): Schema[]
added: static method CreateAclsResponse.schemaVersions(): Schema[]
added: static method CreateDelegationTokenRequest.parse(ByteBuffer, short): CreateDelegationTokenRequest
added: static method CreateDelegationTokenRequest.schemaVersions(): Schema[]
added: static method CreateDelegationTokenResponse.parse(ByteBuffer, short): CreateDelegationTokenResponse
added: static method CreateDelegationTokenResponse.schemaVersions(): Schema[]
added: static method CreatePartitionsRequest.parse(ByteBuffer, short): CreatePartitionsRequest
added: static method CreatePartitionsRequest.schemaVersions(): Schema[]
added: static method CreatePartitionsResponse.parse(ByteBuffer, short): CreatePartitionsResponse
added: static method CreatePartitionsResponse.schemaVersions(): Schema[]
added: static method CreateTopicsRequest.schemaVersions(): Schema[]
added: static method CreateTopicsResponse.schemaVersions(): Schema[]
added: static method DeleteAclsRequest.schemaVersions(): Schema[]
added: static method DeleteAclsResponse.schemaVersions(): Schema[]
added: static method DeleteGroupsRequest.parse(ByteBuffer, short): DeleteGroupsRequest
added: static method DeleteGroupsRequest.schemaVersions(): Schema[]
added: static method DeleteGroupsResponse.parse(ByteBuffer, short): DeleteGroupsResponse
added: static method DeleteGroupsResponse.schemaVersions(): Schema[]
added: static method DeleteRecordsRequest.schemaVersions(): Schema[]
added: static method DeleteRecordsResponse.schemaVersions(): Schema[]
added: static method DeleteTopicsRequest.schemaVersions(): Schema[]
added: static method DeleteTopicsResponse.schemaVersions(): Schema[]
added: static method DescribeAclsRequest.schemaVersions(): Schema[]
added: static method DescribeAclsResponse.schemaVersions(): Schema[]
added: static method DescribeConfigsRequest.schemaVersions(): Schema[]
added: static method DescribeConfigsResponse.ConfigSource.forId(byte): DescribeConfigsResponse.ConfigSource
added: static method DescribeConfigsResponse.ConfigSource.valueOf(String): DescribeConfigsResponse.ConfigSource
added: static method DescribeConfigsResponse.ConfigSource.values(): DescribeConfigsResponse.ConfigSource[]
added: static method DescribeConfigsResponse.schemaVersions(): Schema[]
added: static method DescribeDelegationTokenRequest.parse(ByteBuffer, short): DescribeDelegationTokenRequest
added: static method DescribeDelegationTokenRequest.schemaVersions(): Schema[]
added: static method DescribeDelegationTokenResponse.parse(ByteBuffer, short): DescribeDelegationTokenResponse
added: static method DescribeDelegationTokenResponse.schemaVersions(): Schema[]
added: static method DescribeGroupsRequest.schemaVersions(): Schema[]
added: static method DescribeGroupsResponse.schemaVersions(): Schema[]
added: static method DescribeLogDirsRequest.parse(ByteBuffer, short): DescribeLogDirsRequest
added: static method DescribeLogDirsRequest.schemaVersions(): Schema[]
added: static method DescribeLogDirsResponse.parse(ByteBuffer, short): DescribeLogDirsResponse
added: static method DescribeLogDirsResponse.schemaVersions(): Schema[]
added: static method EndTxnRequest.schemaVersions(): Schema[]
added: static method EndTxnResponse.schemaVersions(): Schema[]
added: static method ExpireDelegationTokenRequest.parse(ByteBuffer, short): ExpireDelegationTokenRequest
added: static method ExpireDelegationTokenRequest.schemaVersions(): Schema[]
added: static method ExpireDelegationTokenResponse.parse(ByteBuffer, short): ExpireDelegationTokenResponse
added: static method ExpireDelegationTokenResponse.schemaVersions(): Schema[]
added: static method FetchMetadata.newIncremental(int): FetchMetadata
added: static method FetchMetadata.nextEpoch(int): int
added: static method FetchRequest.schemaVersions(): Schema[]
added: static method FetchResponse.schemaVersions(): Schema[]
added: static method FindCoordinatorRequest.schemaVersions(): Schema[]
added: static method FindCoordinatorResponse.schemaVersions(): Schema[]
added: static method HeartbeatRequest.schemaVersions(): Schema[]
added: static method HeartbeatResponse.schemaVersions(): Schema[]
added: static method InitProducerIdRequest.schemaVersions(): Schema[]
added: static method InitProducerIdResponse.schemaVersions(): Schema[]
added: static method JoinGroupRequest.schemaVersions(): Schema[]
added: static method JoinGroupResponse.schemaVersions(): Schema[]
added: static method LeaderAndIsrRequest.schemaVersions(): Schema[]
added: static method LeaderAndIsrResponse.schemaVersions(): Schema[]
added: static method LeaveGroupRequest.schemaVersions(): Schema[]
added: static method LeaveGroupResponse.schemaVersions(): Schema[]
added: static method ListGroupsRequest.schemaVersions(): Schema[]
added: static method ListGroupsResponse.schemaVersions(): Schema[]
added: static method ListOffsetRequest.schemaVersions(): Schema[]
added: static method ListOffsetResponse.schemaVersions(): Schema[]
added: static method MetadataRequest.schemaVersions(): Schema[]
added: static method MetadataResponse.schemaVersions(): Schema[]
added: static method OffsetCommitRequest.schemaVersions(): Schema[]
added: static method OffsetCommitResponse.schemaVersions(): Schema[]
added: static method OffsetFetchRequest.schemaVersions(): Schema[]
added: static method OffsetFetchResponse.schemaVersions(): Schema[]
added: static method OffsetsForLeaderEpochRequest.schemaVersions(): Schema[]
added: static method OffsetsForLeaderEpochResponse.schemaVersions(): Schema[]
added: static method ProduceRequest.Builder.forCurrentMagic(short, int, Map): ProduceRequest.Builder
added: static method ProduceRequest.Builder.forMagic(byte, short, int, Map, String): ProduceRequest.Builder
added: static method ProduceRequest.schemaVersions(): Schema[]
added: static method ProduceResponse.schemaVersions(): Schema[]
added: static method RenewDelegationTokenRequest.parse(ByteBuffer, short): RenewDelegationTokenRequest
added: static method RenewDelegationTokenRequest.schemaVersions(): Schema[]
added: static method RenewDelegationTokenResponse.parse(ByteBuffer, short): RenewDelegationTokenResponse
added: static method RenewDelegationTokenResponse.schemaVersions(): Schema[]
added: static method SaslAuthenticateRequest.parse(ByteBuffer, short): SaslAuthenticateRequest
added: static method SaslAuthenticateRequest.schemaVersions(): Schema[]
added: static method SaslAuthenticateResponse.parse(ByteBuffer, short): SaslAuthenticateResponse
added: static method SaslAuthenticateResponse.schemaVersions(): Schema[]
added: static method SaslHandshakeRequest.schemaVersions(): Schema[]
added: static method SaslHandshakeResponse.schemaVersions(): Schema[]
added: static method StopReplicaRequest.schemaVersions(): Schema[]
added: static method StopReplicaResponse.schemaVersions(): Schema[]
added: static method SyncGroupRequest.schemaVersions(): Schema[]
added: static method SyncGroupResponse.schemaVersions(): Schema[]
added: static method TxnOffsetCommitRequest.schemaVersions(): Schema[]
added: static method TxnOffsetCommitResponse.schemaVersions(): Schema[]
added: static method UpdateMetadataRequest.schemaVersions(): Schema[]
added: static method UpdateMetadataResponse.schemaVersions(): Schema[]
added: static method WriteTxnMarkersRequest.schemaVersions(): Schema[]
added: static method WriteTxnMarkersResponse.schemaVersions(): Schema[]

added: static field ResourceType.DELEGATION_TOKEN: ResourceType

removed: ctor JaasUtils()
removed: static method JaasContext.load(JaasContext.Type, ListenerName, Map): JaasContext
changed: class JaasUtils → final class JaasUtils
changed: ctor JaasContext(String, JaasContext.Type, Configuration) → ctor JaasContext(String, JaasContext.Type, Configuration, Password)
added: method JaasContext.dynamicJaasConfig(): Password
added: static method JaasContext.loadClientContext(Map): JaasContext
added: static method JaasContext.loadServerContext(ListenerName, String, Map): JaasContext

removed: interface AuthCallbackHandler extends CallbackHandler
removed: interface Login
removed: method AuthCallbackHandler.close(): void
removed: method AuthCallbackHandler.configure(Map, Mode, Subject, String): void
removed: method Login.close(): void
removed: method Login.configure(Map, JaasContext): void
removed: method Login.login(): LoginContext
removed: method Login.serviceName(): String
removed: method Login.subject(): Subject
removed: static field KafkaPrincipal.SEPARATOR: String
added: class PlaintextAuthenticationContext implements AuthenticationContext
added: class SaslAuthenticationContext implements AuthenticationContext
added: class SslAuthenticationContext implements AuthenticationContext
added: ctor PlaintextAuthenticationContext(InetAddress)
added: ctor SaslAuthenticationContext(SaslServer, SecurityProtocol, InetAddress)
added: ctor SslAuthenticationContext(SSLSession, InetAddress)
added: enum SecurityProtocol
added: field SecurityProtocol.id: short
added: field SecurityProtocol.name: String
added: interface AuthenticationContext
added: interface KafkaPrincipalBuilder
added: method AuthenticationContext.clientAddress(): InetAddress
added: method AuthenticationContext.securityProtocol(): SecurityProtocol
added: method KafkaPrincipal.tokenAuthenticated(): boolean
added: method KafkaPrincipal.tokenAuthenticated(boolean): void
added: method KafkaPrincipalBuilder.build(AuthenticationContext): KafkaPrincipal
added: method PlaintextAuthenticationContext.clientAddress(): InetAddress
added: method PlaintextAuthenticationContext.securityProtocol(): SecurityProtocol
added: method SaslAuthenticationContext.clientAddress(): InetAddress
added: method SaslAuthenticationContext.securityProtocol(): SecurityProtocol
added: method SaslAuthenticationContext.server(): SaslServer
added: method SslAuthenticationContext.clientAddress(): InetAddress
added: method SslAuthenticationContext.securityProtocol(): SecurityProtocol
added: method SslAuthenticationContext.session(): SSLSession
added: static field SecurityProtocol.PLAINTEXT: SecurityProtocol
added: static field SecurityProtocol.SASL_PLAINTEXT: SecurityProtocol
added: static field SecurityProtocol.SASL_SSL: SecurityProtocol
added: static field SecurityProtocol.SSL: SecurityProtocol
added: static method SecurityProtocol.forId(short): SecurityProtocol
added: static method SecurityProtocol.forName(String): SecurityProtocol
added: static method SecurityProtocol.names(): List
added: static method SecurityProtocol.valueOf(String): SecurityProtocol
added: static method SecurityProtocol.values(): SecurityProtocol[]

removed: enum SaslServerAuthenticator.SaslState
removed: method SaslClientAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
removed: method SaslServerAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
removed: static field SaslServerAuthenticator.SaslState.AUTHENTICATE: SaslServerAuthenticator.SaslState
removed: static field SaslServerAuthenticator.SaslState.COMPLETE: SaslServerAuthenticator.SaslState
removed: static field SaslServerAuthenticator.SaslState.FAILED: SaslServerAuthenticator.SaslState
removed: static field SaslServerAuthenticator.SaslState.GSSAPI_OR_HANDSHAKE_REQUEST: SaslServerAuthenticator.SaslState
removed: static field SaslServerAuthenticator.SaslState.HANDSHAKE_REQUEST: SaslServerAuthenticator.SaslState
removed: static method SaslServerAuthenticator.SaslState.valueOf(String): SaslServerAuthenticator.SaslState
removed: static method SaslServerAuthenticator.SaslState.values(): SaslServerAuthenticator.SaslState[]
changed: ctor SaslClientAuthenticator(String, Subject, String, String, String, boolean) → ctor SaslClientAuthenticator(Map, String, Subject, String, String, String, boolean, TransportLayer)
changed: ctor SaslServerAuthenticator(String, JaasContext, Subject, KerberosShortNamer, String, CredentialCache) → ctor SaslServerAuthenticator(Map, String, Map, Map, KerberosShortNamer, CredentialCache, ListenerName, SecurityProtocol, TransportLayer, DelegationTokenCache)
changed: ctor SaslServerCallbackHandler(JaasContext, KerberosShortNamer) → ctor SaslServerCallbackHandler(JaasContext)
changed: method SaslClientAuthenticator.principal(): Principal → method SaslClientAuthenticator.principal(): KafkaPrincipal
changed: method SaslServerAuthenticator.principal(): Principal → method SaslServerAuthenticator.principal(): KafkaPrincipal
changed: static method LoginManager.acquireLoginManager(JaasContext, boolean, Map): LoginManager → static method LoginManager.acquireLoginManager(JaasContext, String, boolean, Map): LoginManager
added: class DefaultKafkaPrincipalBuilder implements KafkaPrincipalBuilder, Closeable
added: ctor DefaultKafkaPrincipalBuilder(KerberosShortNamer)
added: interface AuthCallbackHandler extends CallbackHandler
added: interface Login
added: method AuthCallbackHandler.close(): void
added: method AuthCallbackHandler.configure(Map, Mode, Subject, String): void
added: method DefaultKafkaPrincipalBuilder.build(AuthenticationContext): KafkaPrincipal
added: method DefaultKafkaPrincipalBuilder.close(): void
added: method Login.close(): void
added: method Login.configure(Map, JaasContext): void
added: method Login.login(): LoginContext
added: method Login.serviceName(): String
added: method Login.subject(): Subject
added: method SaslClientAuthenticator.createSaslHandshakeRequest(short): SaslHandshakeRequest
added: method SaslClientAuthenticator.saslAuthenticateVersion(short): void
added: method SaslServerAuthenticator.apiVersionsResponse(): ApiVersionsResponse
added: method SaslServerAuthenticator.enableKafkaSaslAuthenticateHeaders(boolean): void
added: static field SaslClientAuthenticator.SaslState.CLIENT_COMPLETE: SaslClientAuthenticator.SaslState
added: static field SaslClientAuthenticator.SaslState.RECEIVE_APIVERSIONS_RESPONSE: SaslClientAuthenticator.SaslState
added: static field SaslClientAuthenticator.SaslState.SEND_APIVERSIONS_REQUEST: SaslClientAuthenticator.SaslState
added: static method DefaultKafkaPrincipalBuilder.fromOldPrincipalBuilder(Authenticator, TransportLayer, PrincipalBuilder, KerberosShortNamer): DefaultKafkaPrincipalBuilder

removed: ctor ScramCredentialUtils()
changed: class ScramCredentialUtils → final class ScramCredentialUtils
changed: ctor ScramMessages.ClientFirstMessage(String, String) → ctor ScramMessages.ClientFirstMessage(String, String, Map)
changed: ctor ScramServerCallbackHandler(CredentialCache.Cache) → ctor ScramServerCallbackHandler(CredentialCache.Cache, DelegationTokenCache)
added: class ScramExtensions
added: class ScramExtensionsCallback implements Callback
added: ctor ScramExtensions()
added: ctor ScramExtensions(Map)
added: ctor ScramExtensions(String)
added: ctor ScramExtensionsCallback()
added: method ScramExtensions.extensionNames(): Set
added: method ScramExtensions.extensionValue(String): String
added: method ScramExtensions.toString(): String
added: method ScramExtensions.tokenAuthenticated(): boolean
added: method ScramExtensionsCallback.extensions(): Map
added: method ScramExtensionsCallback.extensions(Map): void
added: method ScramMessages.ClientFirstMessage.extensions(): ScramExtensions
added: static field ScramLoginModule.TOKEN_AUTH_CONFIG: String

changed: class SslFactory implements Configurable → class SslFactory implements Reconfigurable
changed: ctor SslFactory(Mode, String) → ctor SslFactory(Mode, String, boolean)
added: method SslFactory.reconfigurableConfigs(): Set
added: method SslFactory.reconfigure(Map): void
added: method SslFactory.validateReconfiguration(Map): void

added: class DelegationToken
added: class DelegationTokenCache
added: class DelegationTokenCredentialCallback extends ScramCredentialCallback
added: class TokenInformation
added: ctor DelegationToken(TokenInformation, byte[])
added: ctor DelegationTokenCache(Collection)
added: ctor DelegationTokenCredentialCallback()
added: ctor TokenInformation(String, KafkaPrincipal, Collection, long, long, long)
added: method DelegationToken.equals(Object): boolean
added: method DelegationToken.hashCode(): int
added: method DelegationToken.hmac(): byte[]
added: method DelegationToken.hmacAsBase64String(): String
added: method DelegationToken.hmacBuffer(): ByteBuffer
added: method DelegationToken.toString(): String
added: method DelegationToken.tokenInfo(): TokenInformation
added: method DelegationTokenCache.addToken(String, TokenInformation): TokenInformation
added: method DelegationTokenCache.credential(String, String): ScramCredential
added: method DelegationTokenCache.credentialCache(String): CredentialCache.Cache
added: method DelegationTokenCache.owner(String): String
added: method DelegationTokenCache.removeCache(String): void
added: method DelegationTokenCache.removeToken(String): void
added: method DelegationTokenCache.token(String): TokenInformation
added: method DelegationTokenCache.tokenForHmac(String): TokenInformation
added: method DelegationTokenCache.tokens(): Collection
added: method DelegationTokenCache.updateCache(DelegationToken, Map): void
added: method DelegationTokenCredentialCallback.tokenOwner(): String
added: method DelegationTokenCredentialCallback.tokenOwner(String): void
added: method TokenInformation.equals(Object): boolean
added: method TokenInformation.expiryTimestamp(): long
added: method TokenInformation.hashCode(): int
added: method TokenInformation.issueTimestamp(): long
added: method TokenInformation.maxTimestamp(): long
added: method TokenInformation.owner(): KafkaPrincipal
added: method TokenInformation.ownerAsString(): String
added: method TokenInformation.ownerOrRenewer(KafkaPrincipal): boolean
added: method TokenInformation.renewers(): Collection
added: method TokenInformation.renewersAsString(): Collection
added: method TokenInformation.setExpiryTimestamp(long): void
added: method TokenInformation.toString(): String
added: method TokenInformation.tokenId(): String

removed: ctor CollectionUtils()
removed: ctor Crc32C()
removed: ctor Utils()
removed: static field Java.JVM_SPEC_VERSION: String
removed: static method Java.isIBMJdk(): boolean
removed: static method Utils.daemonThread(String, Runnable): Thread
removed: static method Utils.newThread(String, Runnable, boolean): Thread
changed: class CollectionUtils → final class CollectionUtils
changed: class Crc32C → final class Crc32C
changed: class Utils → final class Utils
changed: static method AppInfoParser.registerAppInfo(String, String): void → static method AppInfoParser.registerAppInfo(String, String, Metrics): void
changed: static method AppInfoParser.unregisterAppInfo(String, String): void → static method AppInfoParser.unregisterAppInfo(String, String, Metrics): void
added: class ImplicitLinkedHashSet extends AbstractSet
added: class LogContext
added: class LoggingSignalHandler
added: class Sanitizer
added: class SecurityUtils
added: class SystemScheduler implements Scheduler
added: ctor ImplicitLinkedHashSet()
added: ctor ImplicitLinkedHashSet(int)
added: ctor LogContext()
added: ctor LogContext(String)
added: ctor LoggingSignalHandler()
added: ctor Sanitizer()
added: ctor SecurityUtils()
added: final class Base64
added: final class MappedByteBuffers
added: interface Base64.Decoder
added: interface Base64.Encoder
added: interface ImplicitLinkedHashSet.Element
added: interface Scheduler
added: method Base64.Decoder.decode(String): byte[]
added: method Base64.Encoder.encodeToString(byte[]): String
added: method ImplicitLinkedHashSet.Element.next(): int
added: method ImplicitLinkedHashSet.Element.prev(): int
added: method ImplicitLinkedHashSet.Element.setNext(int): void
added: method ImplicitLinkedHashSet.Element.setPrev(int): void
added: method ImplicitLinkedHashSet.add(ImplicitLinkedHashSet.Element): boolean
added: method ImplicitLinkedHashSet.clear(): void
added: method ImplicitLinkedHashSet.contains(Object): boolean
added: method ImplicitLinkedHashSet.find(ImplicitLinkedHashSet.Element): ImplicitLinkedHashSet.Element
added: method ImplicitLinkedHashSet.iterator(): Iterator
added: method ImplicitLinkedHashSet.mustAdd(ImplicitLinkedHashSet.Element): void
added: method ImplicitLinkedHashSet.remove(Object): boolean
added: method ImplicitLinkedHashSet.size(): int
added: method LogContext.logPrefix(): String
added: method LogContext.logger(Class): Logger
added: method LoggingSignalHandler.register(): void
added: method Scheduler.schedule(ScheduledExecutorService, Callable, long): Future
added: method Scheduler.time(): Time
added: method SystemScheduler.schedule(ScheduledExecutorService, Callable, long): Future
added: method SystemScheduler.time(): Time
added: static field ImplicitLinkedHashSet.INVALID_INDEX: int
added: static field Java.IS_JAVA8_COMPATIBLE: boolean
added: static field Scheduler.SYSTEM: Scheduler
added: static method Base64.decoder(): Base64.Decoder
added: static method Base64.encoder(): Base64.Encoder
added: static method Base64.urlDecoder(): Base64.Decoder
added: static method Base64.urlEncoderNoPadding(): Base64.Encoder
added: static method Java.isIbmJdk(): boolean
added: static method KafkaThread.daemon(String, Runnable): KafkaThread
added: static method KafkaThread.nonDaemon(String, Runnable): KafkaThread
added: static method MappedByteBuffers.unmap(String, MappedByteBuffer): void
added: static method Sanitizer.desanitize(String): String
added: static method Sanitizer.jmxSanitize(String): String
added: static method Sanitizer.sanitize(String): String
added: static method SecurityUtils.parseKafkaPrincipal(String): KafkaPrincipal
added: static method Utils.formatBytes(long): String
added: static method Utils.loadClass(String, Class): Class
added: static method Utils.newParameterizedInstance(String, Object[]): Object