Upgrading org.apache.kafka:kafka-clients 0.8 to 0.9

Unknown0.8.2.2 → 0.9.0.1

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

Fetching 2 releases from Maven Central…0 / 2

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.

API changes

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

removed: method ClientRequest.attachment(): Object
removed: method ClientRequest.createdTime(): long
removed: method ClientResponse.receivedTime(): long
changed: ctor ClientRequest(long, boolean, RequestSend, Object) → ctor ClientRequest(long, boolean, RequestSend, RequestCompletionHandler)
changed: ctor NetworkClient(Selectable, Metadata, String, int, long, int, int) → ctor NetworkClient(Selectable, Metadata, String, int, long, int, int, int, Time)
changed: interface KafkaClient → interface KafkaClient extends Closeable
changed: method KafkaClient.close(): void → method KafkaClient.close(String): void
changed: method KafkaClient.poll(List, long, long): List → method KafkaClient.poll(long, long): List
changed: method NetworkClient.poll(List, long, long): List → method NetworkClient.poll(long, long): List
added: class ClientUtils
added: class CommonClientConfigs
added: class ManualMetadataUpdater implements MetadataUpdater
added: ctor ClientRequest(long, boolean, RequestSend, RequestCompletionHandler, boolean)
added: ctor ClientUtils()
added: ctor CommonClientConfigs()
added: ctor ManualMetadataUpdater()
added: ctor ManualMetadataUpdater(List)
added: ctor Metadata()
added: ctor Metadata(long, long)
added: ctor NetworkClient(Selectable, MetadataUpdater, String, int, long, int, int, int, Time)
added: enum ConnectionState
added: final class Metadata
added: interface Metadata.Listener
added: interface RequestCompletionHandler
added: method ClientRequest.callback(): RequestCompletionHandler
added: method ClientRequest.createdTimeMs(): long
added: method ClientRequest.hasCallback(): boolean
added: method ClientRequest.isInitiatedByNetworkClient(): boolean
added: method ClientRequest.sendTimeMs(): long
added: method ClientRequest.setSendTimeMs(long): void
added: method ClientResponse.receivedTimeMs(): long
added: method KafkaClient.connectionFailed(Node): boolean
added: method KafkaClient.inFlightRequestCount(String): int
added: method KafkaClient.nextRequestHeader(ApiKeys, short): RequestHeader
added: method KafkaClient.send(ClientRequest, long): void
added: method ManualMetadataUpdater.fetchNodes(): List
added: method ManualMetadataUpdater.isUpdateDue(long): boolean
added: method ManualMetadataUpdater.maybeHandleCompletedReceive(ClientRequest, long, Struct): boolean
added: method ManualMetadataUpdater.maybeHandleDisconnection(ClientRequest): boolean
added: method ManualMetadataUpdater.maybeUpdate(long): long
added: method ManualMetadataUpdater.requestUpdate(): void
added: method ManualMetadataUpdater.setNodes(List): void
added: method Metadata.Listener.onMetadataUpdate(Cluster): void
added: method Metadata.add(String): void
added: method Metadata.addListener(Metadata.Listener): void
added: method Metadata.awaitUpdate(int, long): void
added: method Metadata.containsTopic(String): boolean
added: method Metadata.failedUpdate(long): void
added: method Metadata.fetch(): Cluster
added: method Metadata.lastSuccessfulUpdate(): long
added: method Metadata.needMetadataForAllTopics(): boolean
added: method Metadata.needMetadataForAllTopics(boolean): void
added: method Metadata.refreshBackoff(): long
added: method Metadata.removeListener(Metadata.Listener): void
added: method Metadata.requestUpdate(): int
added: method Metadata.setTopics(Collection): void
added: method Metadata.timeToNextUpdate(long): long
added: method Metadata.topics(): Set
added: method Metadata.update(Cluster, long): void
added: method Metadata.version(): int
added: method NetworkClient.close(String): void
added: method NetworkClient.connectionFailed(Node): boolean
added: method NetworkClient.inFlightRequestCount(String): int
added: method NetworkClient.nextRequestHeader(ApiKeys, short): RequestHeader
added: method NetworkClient.send(ClientRequest, long): void
added: method RequestCompletionHandler.onComplete(ClientResponse): void
added: static field CommonClientConfigs.BOOSTRAP_SERVERS_DOC: String
added: static field CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG: String
added: static field CommonClientConfigs.CLIENT_ID_CONFIG: String
added: static field CommonClientConfigs.CLIENT_ID_DOC: String
added: static field CommonClientConfigs.CONNECTIONS_MAX_IDLE_MS_CONFIG: String
added: static field CommonClientConfigs.CONNECTIONS_MAX_IDLE_MS_DOC: String
added: static field CommonClientConfigs.DEFAULT_SECURITY_PROTOCOL: String
added: static field CommonClientConfigs.METADATA_MAX_AGE_CONFIG: String
added: static field CommonClientConfigs.METADATA_MAX_AGE_DOC: String
added: static field CommonClientConfigs.METRICS_NUM_SAMPLES_CONFIG: String
added: static field CommonClientConfigs.METRICS_NUM_SAMPLES_DOC: String
added: static field CommonClientConfigs.METRICS_SAMPLE_WINDOW_MS_CONFIG: String
added: static field CommonClientConfigs.METRICS_SAMPLE_WINDOW_MS_DOC: String
added: static field CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG: String
added: static field CommonClientConfigs.METRIC_REPORTER_CLASSES_DOC: String
added: static field CommonClientConfigs.RECEIVE_BUFFER_CONFIG: String
added: static field CommonClientConfigs.RECEIVE_BUFFER_DOC: String
added: static field CommonClientConfigs.RECONNECT_BACKOFF_MS_CONFIG: String
added: static field CommonClientConfigs.RECONNECT_BACKOFF_MS_DOC: String
added: static field CommonClientConfigs.REQUEST_TIMEOUT_MS_CONFIG: String
added: static field CommonClientConfigs.REQUEST_TIMEOUT_MS_DOC: String
added: static field CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG: String
added: static field CommonClientConfigs.RETRY_BACKOFF_MS_DOC: String
added: static field CommonClientConfigs.SECURITY_PROTOCOL_CONFIG: String
added: static field CommonClientConfigs.SECURITY_PROTOCOL_DOC: String
added: static field CommonClientConfigs.SEND_BUFFER_CONFIG: String
added: static field CommonClientConfigs.SEND_BUFFER_DOC: String
added: static field ConnectionState.CONNECTED: ConnectionState
added: static field ConnectionState.CONNECTING: ConnectionState
added: static field ConnectionState.DISCONNECTED: ConnectionState
added: static method ClientUtils.closeQuietly(Closeable, String, AtomicReference): void
added: static method ClientUtils.createChannelBuilder(Map): ChannelBuilder
added: static method ClientUtils.parseAndValidateAddresses(List): List
added: static method ConnectionState.valueOf(String): ConnectionState
added: static method ConnectionState.values(): ConnectionState[]

removed: ctor ConsumerRecord(String, int, Object, Object, long)
removed: ctor ConsumerRecord(String, int, Object, long)
removed: ctor KafkaConsumer(Properties, ConsumerRebalanceCallback)
removed: ctor KafkaConsumer(Properties, ConsumerRebalanceCallback, Deserializer, Deserializer)
removed: ctor OffsetMetadata(Map)
removed: ctor OffsetMetadata(Map, Map)
removed: final class OffsetMetadata
removed: interface ConsumerRebalanceCallback
removed: method Consumer.commit(Map, boolean): OffsetMetadata
removed: method Consumer.commit(boolean): OffsetMetadata
removed: method Consumer.offsetsBeforeTime(long, Collection): Map
removed: method Consumer.unsubscribe(TopicPartition[]): void
removed: method ConsumerRebalanceCallback.onPartitionsAssigned(Consumer, Collection): void
removed: method ConsumerRebalanceCallback.onPartitionsRevoked(Consumer, Collection): void
removed: method ConsumerRecord.error(): Exception
removed: method ConsumerRecord.topicAndPartition(): TopicPartition
removed: method ConsumerRecords.topic(): String
removed: method KafkaConsumer.commit(Map, boolean): OffsetMetadata
removed: method KafkaConsumer.commit(boolean): OffsetMetadata
removed: method KafkaConsumer.offsetsBeforeTime(long, Collection): Map
removed: method KafkaConsumer.unsubscribe(TopicPartition[]): void
removed: method MockConsumer.commit(Map, boolean): OffsetMetadata
removed: method MockConsumer.commit(boolean): OffsetMetadata
removed: method MockConsumer.offsetsBeforeTime(long, Collection): Map
removed: method MockConsumer.unsubscribe(TopicPartition[]): void
removed: method OffsetMetadata.error(TopicPartition): Exception
removed: method OffsetMetadata.offset(TopicPartition): long
removed: static field ConsumerConfig.FETCH_BUFFER_CONFIG: String
removed: static field ConsumerConfig.HEARTBEAT_FREQUENCY: String
removed: static field ConsumerConfig.METADATA_FETCH_TIMEOUT_CONFIG: String
removed: static field ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY: String
removed: static field ConsumerConfig.SESSION_TIMEOUT_MS: String
removed: static field ConsumerConfig.SOCKET_RECEIVE_BUFFER_CONFIG: String
removed: static field ConsumerConfig.TOTAL_BUFFER_MEMORY_CONFIG: String
changed: class ConsumerRecords → class ConsumerRecords implements Iterable
changed: ctor ConsumerRecord(String, int, Exception) → ctor ConsumerRecord(String, int, long, Object, Object)
changed: ctor ConsumerRecords(String, Map) → ctor ConsumerRecords(Map)
changed: ctor KafkaConsumer(Map, ConsumerRebalanceCallback) → ctor KafkaConsumer(Map, Deserializer, Deserializer)
changed: ctor KafkaConsumer(Map, ConsumerRebalanceCallback, Deserializer, Deserializer) → ctor KafkaConsumer(Properties, Deserializer, Deserializer)
changed: ctor MockConsumer() → ctor MockConsumer(OffsetResetStrategy)
changed: method Consumer.committed(Collection): Map → method Consumer.committed(TopicPartition): OffsetAndMetadata
changed: method Consumer.poll(long): Map → method Consumer.poll(long): ConsumerRecords
changed: method Consumer.position(Collection): Map → method Consumer.position(TopicPartition): long
changed: method Consumer.seek(Map): void → method Consumer.seek(TopicPartition, long): void
changed: method Consumer.subscribe(String[]): void → method Consumer.subscribe(List): void
changed: method Consumer.subscribe(TopicPartition[]): void → method Consumer.subscribe(List, ConsumerRebalanceListener): void
changed: method Consumer.unsubscribe(String[]): void → method Consumer.unsubscribe(): void
changed: method ConsumerRecords.records(int[]): List → method ConsumerRecords.records(String): Iterable
changed: method KafkaConsumer.committed(Collection): Map → method KafkaConsumer.committed(TopicPartition): OffsetAndMetadata
changed: method KafkaConsumer.poll(long): Map → method KafkaConsumer.poll(long): ConsumerRecords
changed: method KafkaConsumer.position(Collection): Map → method KafkaConsumer.position(TopicPartition): long
changed: method KafkaConsumer.seek(Map): void → method KafkaConsumer.seek(TopicPartition, long): void
changed: method KafkaConsumer.subscribe(String[]): void → method KafkaConsumer.subscribe(List): void
changed: method KafkaConsumer.subscribe(TopicPartition[]): void → method KafkaConsumer.subscribe(List, ConsumerRebalanceListener): void
changed: method KafkaConsumer.unsubscribe(String[]): void → method KafkaConsumer.unsubscribe(): void
changed: method MockConsumer.committed(Collection): Map → method MockConsumer.committed(TopicPartition): OffsetAndMetadata
changed: method MockConsumer.poll(long): Map → method MockConsumer.poll(long): ConsumerRecords
changed: method MockConsumer.position(Collection): Map → method MockConsumer.position(TopicPartition): long
changed: method MockConsumer.seek(Map): void → method MockConsumer.seek(TopicPartition, long): void
changed: method MockConsumer.subscribe(String[]): void → method MockConsumer.subscribe(List): void
changed: method MockConsumer.subscribe(TopicPartition[]): void → method MockConsumer.subscribe(List, ConsumerRebalanceListener): void
changed: method MockConsumer.unsubscribe(String[]): void → method MockConsumer.unsubscribe(): void
added: abstract class InvalidOffsetException extends KafkaException
added: class CommitFailedException extends KafkaException
added: class NoOffsetForPartitionException extends InvalidOffsetException
added: class OffsetAndMetadata implements Serializable
added: class OffsetOutOfRangeException extends InvalidOffsetException
added: class RangeAssignor extends AbstractPartitionAssignor
added: class RoundRobinAssignor extends AbstractPartitionAssignor
added: ctor CommitFailedException(String)
added: ctor InvalidOffsetException(String)
added: ctor NoOffsetForPartitionException(TopicPartition)
added: ctor OffsetAndMetadata(long)
added: ctor OffsetAndMetadata(long, String)
added: ctor OffsetOutOfRangeException(Map)
added: ctor RangeAssignor()
added: ctor RoundRobinAssignor()
added: enum OffsetResetStrategy
added: interface ConsumerRebalanceListener
added: interface OffsetCommitCallback
added: method Consumer.assign(List): void
added: method Consumer.assignment(): Set
added: method Consumer.commitAsync(): void
added: method Consumer.commitAsync(Map, OffsetCommitCallback): void
added: method Consumer.commitAsync(OffsetCommitCallback): void
added: method Consumer.commitSync(): void
added: method Consumer.commitSync(Map): void
added: method Consumer.listTopics(): Map
added: method Consumer.partitionsFor(String): List
added: method Consumer.pause(TopicPartition[]): void
added: method Consumer.resume(TopicPartition[]): void
added: method Consumer.seekToBeginning(TopicPartition[]): void
added: method Consumer.seekToEnd(TopicPartition[]): void
added: method Consumer.subscribe(Pattern, ConsumerRebalanceListener): void
added: method Consumer.subscription(): Set
added: method Consumer.wakeup(): void
added: method ConsumerRebalanceListener.onPartitionsAssigned(Collection): void
added: method ConsumerRebalanceListener.onPartitionsRevoked(Collection): void
added: method ConsumerRecord.toString(): String
added: method ConsumerRecords.count(): int
added: method ConsumerRecords.isEmpty(): boolean
added: method ConsumerRecords.iterator(): Iterator
added: method ConsumerRecords.partitions(): Set
added: method ConsumerRecords.records(TopicPartition): List
added: method InvalidOffsetException.partitions(): Set
added: method KafkaConsumer.assign(List): void
added: method KafkaConsumer.assignment(): Set
added: method KafkaConsumer.commitAsync(): void
added: method KafkaConsumer.commitAsync(Map, OffsetCommitCallback): void
added: method KafkaConsumer.commitAsync(OffsetCommitCallback): void
added: method KafkaConsumer.commitSync(): void
added: method KafkaConsumer.commitSync(Map): void
added: method KafkaConsumer.listTopics(): Map
added: method KafkaConsumer.partitionsFor(String): List
added: method KafkaConsumer.pause(TopicPartition[]): void
added: method KafkaConsumer.resume(TopicPartition[]): void
added: method KafkaConsumer.seekToBeginning(TopicPartition[]): void
added: method KafkaConsumer.seekToEnd(TopicPartition[]): void
added: method KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener): void
added: method KafkaConsumer.subscription(): Set
added: method KafkaConsumer.wakeup(): void
added: method MockConsumer.addRecord(ConsumerRecord): void
added: method MockConsumer.assign(List): void
added: method MockConsumer.assignment(): Set
added: method MockConsumer.closed(): boolean
added: method MockConsumer.commitAsync(): void
added: method MockConsumer.commitAsync(Map, OffsetCommitCallback): void
added: method MockConsumer.commitAsync(OffsetCommitCallback): void
added: method MockConsumer.commitSync(): void
added: method MockConsumer.commitSync(Map): void
added: method MockConsumer.listTopics(): Map
added: method MockConsumer.partitionsFor(String): List
added: method MockConsumer.pause(TopicPartition[]): void
added: method MockConsumer.paused(): Set
added: method MockConsumer.rebalance(Collection): void
added: method MockConsumer.resume(TopicPartition[]): void
added: method MockConsumer.scheduleNopPollTask(): void
added: method MockConsumer.schedulePollTask(Runnable): void
added: method MockConsumer.seekToBeginning(TopicPartition[]): void
added: method MockConsumer.seekToEnd(TopicPartition[]): void
added: method MockConsumer.setException(KafkaException): void
added: method MockConsumer.subscribe(Pattern, ConsumerRebalanceListener): void
added: method MockConsumer.subscription(): Set
added: method MockConsumer.updateBeginningOffsets(Map): void
added: method MockConsumer.updateEndOffsets(Map): void
added: method MockConsumer.updatePartitions(String, List): void
added: method MockConsumer.wakeup(): void
added: method NoOffsetForPartitionException.partition(): TopicPartition
added: method NoOffsetForPartitionException.partitions(): Set
added: method OffsetAndMetadata.equals(Object): boolean
added: method OffsetAndMetadata.hashCode(): int
added: method OffsetAndMetadata.metadata(): String
added: method OffsetAndMetadata.offset(): long
added: method OffsetAndMetadata.toString(): String
added: method OffsetCommitCallback.onComplete(Map, Exception): void
added: method OffsetOutOfRangeException.offsetOutOfRangePartitions(): Map
added: method OffsetOutOfRangeException.partitions(): Set
added: method RangeAssignor.assign(Map, Map): Map
added: method RangeAssignor.name(): String
added: method RoundRobinAssignor.allPartitionsSorted(Map, Map): List
added: method RoundRobinAssignor.assign(Map, Map): Map
added: method RoundRobinAssignor.name(): String
added: static field ConsumerConfig.CHECK_CRCS_CONFIG: String
added: static field ConsumerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG: String
added: static field ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG: String
added: static field ConsumerConfig.KEY_DESERIALIZER_CLASS_DOC: String
added: static field ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG: String
added: static field ConsumerConfig.METADATA_MAX_AGE_CONFIG: String
added: static field ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG: String
added: static field ConsumerConfig.RECEIVE_BUFFER_CONFIG: String
added: static field ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG: String
added: static field ConsumerConfig.RETRY_BACKOFF_MS_CONFIG: String
added: static field ConsumerConfig.SEND_BUFFER_CONFIG: String
added: static field ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG: String
added: static field ConsumerConfig.VALUE_DESERIALIZER_CLASS_DOC: String
added: static field ConsumerRecords.EMPTY: ConsumerRecords
added: static field OffsetResetStrategy.EARLIEST: OffsetResetStrategy
added: static field OffsetResetStrategy.LATEST: OffsetResetStrategy
added: static field OffsetResetStrategy.NONE: OffsetResetStrategy
added: static method ConsumerConfig.addDeserializerToConfig(Map, Deserializer, Deserializer): Map
added: static method ConsumerConfig.addDeserializerToConfig(Properties, Deserializer, Deserializer): Properties
added: static method ConsumerConfig.main(String[]): void
added: static method ConsumerRecords.empty(): ConsumerRecords
added: static method OffsetResetStrategy.valueOf(String): OffsetResetStrategy
added: static method OffsetResetStrategy.values(): OffsetResetStrategy[]

added: abstract class AbstractCoordinator implements Closeable
added: abstract class AbstractCoordinator.CoordinatorResponseHandler extends RequestFutureAdapter
added: abstract class AbstractPartitionAssignor implements PartitionAssignor
added: abstract class RequestFutureAdapter
added: class ConsumerNetworkClient implements Closeable
added: class ConsumerProtocol
added: class DelayedTaskQueue
added: class Fetcher
added: class NoAvailableBrokersException extends InvalidMetadataException
added: class NoOpConsumerRebalanceListener implements ConsumerRebalanceListener
added: class RequestFuture
added: class SendFailedException extends RetriableException
added: class StaleMetadataException extends InvalidMetadataException
added: class SubscriptionState
added: ctor AbstractCoordinator(ConsumerNetworkClient, String, int, int, Metrics, String, Map, Time, long)
added: ctor AbstractCoordinator.CoordinatorResponseHandler(AbstractCoordinator)
added: ctor AbstractPartitionAssignor()
added: ctor ConsumerCoordinator(ConsumerNetworkClient, String, int, int, List, Metadata, SubscriptionState, Metrics, String, Map, Time, long, OffsetCommitCallback, boolean, long)
added: ctor ConsumerCoordinator.DefaultOffsetCommitCallback()
added: ctor ConsumerNetworkClient(KafkaClient, Metadata, Time, long)
added: ctor ConsumerNetworkClient.RequestFutureCompletionHandler()
added: ctor ConsumerProtocol()
added: ctor DelayedTaskQueue()
added: ctor Fetcher(ConsumerNetworkClient, int, int, int, boolean, Deserializer, Deserializer, Metadata, SubscriptionState, Metrics, String, Map, Time, long)
added: ctor Heartbeat(long, long, long)
added: ctor NoAvailableBrokersException()
added: ctor NoOpConsumerRebalanceListener()
added: ctor PartitionAssignor.Assignment(List)
added: ctor PartitionAssignor.Assignment(List, ByteBuffer)
added: ctor PartitionAssignor.Subscription(List)
added: ctor PartitionAssignor.Subscription(List, ByteBuffer)
added: ctor RequestFuture()
added: ctor RequestFutureAdapter()
added: ctor SendFailedException()
added: ctor StaleMetadataException()
added: ctor SubscriptionState(OffsetResetStrategy)
added: field AbstractCoordinator.CoordinatorResponseHandler.response: ClientResponse
added: field AbstractCoordinator.client: ConsumerNetworkClient
added: field AbstractCoordinator.coordinator: Node
added: field AbstractCoordinator.generation: int
added: field AbstractCoordinator.groupId: String
added: field AbstractCoordinator.memberId: String
added: field AbstractCoordinator.protocol: String
added: field AbstractCoordinator.retryBackoffMs: long
added: field AbstractCoordinator.time: Time
added: final class ConsumerCoordinator extends AbstractCoordinator
added: final class Heartbeat
added: interface DelayedTask
added: interface PartitionAssignor
added: interface RequestFutureListener
added: method AbstractCoordinator.CoordinatorResponseHandler.handle(Object, RequestFuture): void
added: method AbstractCoordinator.CoordinatorResponseHandler.onFailure(RuntimeException, RequestFuture): void
added: method AbstractCoordinator.CoordinatorResponseHandler.onSuccess(ClientResponse, RequestFuture): void
added: method AbstractCoordinator.CoordinatorResponseHandler.parse(ClientResponse): Object
added: method AbstractCoordinator.close(): void
added: method AbstractCoordinator.coordinatorDead(): void
added: method AbstractCoordinator.coordinatorUnknown(): boolean
added: method AbstractCoordinator.ensureActiveGroup(): void
added: method AbstractCoordinator.ensureCoordinatorKnown(): void
added: method AbstractCoordinator.maybeLeaveGroup(): void
added: method AbstractCoordinator.metadata(): List
added: method AbstractCoordinator.needRejoin(): boolean
added: method AbstractCoordinator.onJoinComplete(int, String, String, ByteBuffer): void
added: method AbstractCoordinator.onJoinPrepare(int, String): void
added: method AbstractCoordinator.performAssignment(String, String, Map): Map
added: method AbstractCoordinator.protocolType(): String
added: method AbstractCoordinator.sendHeartbeatRequest(): RequestFuture
added: method AbstractPartitionAssignor.assign(Cluster, Map): Map
added: method AbstractPartitionAssignor.assign(Map, Map): Map
added: method AbstractPartitionAssignor.onAssignment(PartitionAssignor.Assignment): void
added: method AbstractPartitionAssignor.subscription(Set): PartitionAssignor.Subscription
added: method ConsumerCoordinator.DefaultOffsetCommitCallback.onComplete(Map, Exception): void
added: method ConsumerCoordinator.close(): void
added: method ConsumerCoordinator.commitOffsetsAsync(Map, OffsetCommitCallback): void
added: method ConsumerCoordinator.commitOffsetsSync(Map): void
added: method ConsumerCoordinator.ensurePartitionAssignment(): void
added: method ConsumerCoordinator.fetchCommittedOffsets(Set): Map
added: method ConsumerCoordinator.metadata(): List
added: method ConsumerCoordinator.needRejoin(): boolean
added: method ConsumerCoordinator.onJoinComplete(int, String, String, ByteBuffer): void
added: method ConsumerCoordinator.onJoinPrepare(int, String): void
added: method ConsumerCoordinator.performAssignment(String, String, Map): Map
added: method ConsumerCoordinator.protocolType(): String
added: method ConsumerCoordinator.refreshCommittedOffsetsIfNeeded(): void
added: method ConsumerNetworkClient.RequestFutureCompletionHandler.onComplete(ClientResponse): void
added: method ConsumerNetworkClient.awaitMetadataUpdate(): void
added: method ConsumerNetworkClient.awaitPendingRequests(Node): void
added: method ConsumerNetworkClient.close(): void
added: method ConsumerNetworkClient.connectionFailed(Node): boolean
added: method ConsumerNetworkClient.disableWakeups(): void
added: method ConsumerNetworkClient.enableWakeups(): void
added: method ConsumerNetworkClient.ensureFreshMetadata(): void
added: method ConsumerNetworkClient.leastLoadedNode(): Node
added: method ConsumerNetworkClient.pendingRequestCount(): int
added: method ConsumerNetworkClient.pendingRequestCount(Node): int
added: method ConsumerNetworkClient.poll(RequestFuture): void
added: method ConsumerNetworkClient.poll(RequestFuture, long): boolean
added: method ConsumerNetworkClient.poll(long): void
added: method ConsumerNetworkClient.quickPoll(): void
added: method ConsumerNetworkClient.schedule(DelayedTask, long): void
added: method ConsumerNetworkClient.send(Node, ApiKeys, AbstractRequest): RequestFuture
added: method ConsumerNetworkClient.tryConnect(Node): void
added: method ConsumerNetworkClient.unschedule(DelayedTask): void
added: method ConsumerNetworkClient.wakeup(): void
added: method DelayedTask.run(long): void
added: method DelayedTaskQueue.add(DelayedTask, long): void
added: method DelayedTaskQueue.nextTimeout(long): long
added: method DelayedTaskQueue.poll(long): void
added: method DelayedTaskQueue.remove(DelayedTask): boolean
added: method Fetcher.fetchedRecords(): Map
added: method Fetcher.getAllTopicMetadata(long): Map
added: method Fetcher.getTopicMetadata(List, long): Map
added: method Fetcher.initFetches(Cluster): void
added: method Fetcher.updateFetchPositions(Set): void
added: method Heartbeat.interval(): long
added: method Heartbeat.lastHeartbeatSend(): long
added: method Heartbeat.receiveHeartbeat(long): void
added: method Heartbeat.resetSessionTimeout(long): void
added: method Heartbeat.sentHeartbeat(long): void
added: method Heartbeat.sessionTimeoutExpired(long): boolean
added: method Heartbeat.shouldHeartbeat(long): boolean
added: method Heartbeat.timeToNextHeartbeat(long): long
added: method NoOpConsumerRebalanceListener.onPartitionsAssigned(Collection): void
added: method NoOpConsumerRebalanceListener.onPartitionsRevoked(Collection): void
added: method PartitionAssignor.Assignment.partitions(): List
added: method PartitionAssignor.Assignment.userData(): ByteBuffer
added: method PartitionAssignor.Subscription.topics(): List
added: method PartitionAssignor.Subscription.userData(): ByteBuffer
added: method PartitionAssignor.assign(Cluster, Map): Map
added: method PartitionAssignor.name(): String
added: method PartitionAssignor.onAssignment(PartitionAssignor.Assignment): void
added: method PartitionAssignor.subscription(Set): PartitionAssignor.Subscription
added: method RequestFuture.addListener(RequestFutureListener): void
added: method RequestFuture.chain(RequestFuture): void
added: method RequestFuture.complete(Object): void
added: method RequestFuture.compose(RequestFutureAdapter): RequestFuture
added: method RequestFuture.exception(): RuntimeException
added: method RequestFuture.failed(): boolean
added: method RequestFuture.isDone(): boolean
added: method RequestFuture.isRetriable(): boolean
added: method RequestFuture.raise(Errors): void
added: method RequestFuture.raise(RuntimeException): void
added: method RequestFuture.succeeded(): boolean
added: method RequestFuture.value(): Object
added: method RequestFutureAdapter.onFailure(RuntimeException, RequestFuture): void
added: method RequestFutureAdapter.onSuccess(Object, RequestFuture): void
added: method RequestFutureListener.onFailure(RuntimeException): void
added: method RequestFutureListener.onSuccess(Object): void
added: method SubscriptionState.allConsumed(): Map
added: method SubscriptionState.assignFromSubscribed(Collection): void
added: method SubscriptionState.assignFromUser(Collection): void
added: method SubscriptionState.assignedPartitions(): Set
added: method SubscriptionState.changeSubscription(List): void
added: method SubscriptionState.commitsRefreshed(): void
added: method SubscriptionState.committed(TopicPartition): OffsetAndMetadata
added: method SubscriptionState.committed(TopicPartition, OffsetAndMetadata): void
added: method SubscriptionState.fetchablePartitions(): Set
added: method SubscriptionState.getSubscribedPattern(): Pattern
added: method SubscriptionState.groupSubscribe(Collection): void
added: method SubscriptionState.groupSubscription(): Set
added: method SubscriptionState.hasAllFetchPositions(): boolean
added: method SubscriptionState.hasDefaultOffsetResetPolicy(): boolean
added: method SubscriptionState.hasPatternSubscription(): boolean
added: method SubscriptionState.isAssigned(TopicPartition): boolean
added: method SubscriptionState.isFetchable(TopicPartition): boolean
added: method SubscriptionState.isOffsetResetNeeded(TopicPartition): boolean
added: method SubscriptionState.isPaused(TopicPartition): boolean
added: method SubscriptionState.listener(): ConsumerRebalanceListener
added: method SubscriptionState.missingFetchPositions(): Set
added: method SubscriptionState.needOffsetReset(TopicPartition): void
added: method SubscriptionState.needOffsetReset(TopicPartition, OffsetResetStrategy): void
added: method SubscriptionState.needReassignment(): void
added: method SubscriptionState.needRefreshCommits(): void
added: method SubscriptionState.partitionAssignmentNeeded(): boolean
added: method SubscriptionState.partitionsAutoAssigned(): boolean
added: method SubscriptionState.pause(TopicPartition): void
added: method SubscriptionState.position(TopicPartition): Long
added: method SubscriptionState.position(TopicPartition, long): void
added: method SubscriptionState.refreshCommitsNeeded(): boolean
added: method SubscriptionState.resetStrategy(TopicPartition): OffsetResetStrategy
added: method SubscriptionState.resume(TopicPartition): void
added: method SubscriptionState.seek(TopicPartition, long): void
added: method SubscriptionState.subscribe(List, ConsumerRebalanceListener): void
added: method SubscriptionState.subscribe(Pattern, ConsumerRebalanceListener): void
added: method SubscriptionState.subscription(): Set
added: method SubscriptionState.unsubscribe(): void
added: static class ConsumerCoordinator.DefaultOffsetCommitCallback implements OffsetCommitCallback
added: static class ConsumerNetworkClient.RequestFutureCompletionHandler extends RequestFuture implements RequestCompletionHandler
added: static class PartitionAssignor.Assignment
added: static class PartitionAssignor.Subscription
added: static field ConsumerProtocol.ASSIGNMENT_V0: Schema
added: static field ConsumerProtocol.CONSUMER_PROTOCOL_HEADER_SCHEMA: Schema
added: static field ConsumerProtocol.CONSUMER_PROTOCOL_V0: short
added: static field ConsumerProtocol.PARTITIONS_KEY_NAME: String
added: static field ConsumerProtocol.PROTOCOL_TYPE: String
added: static field ConsumerProtocol.SUBSCRIPTION_V0: Schema
added: static field ConsumerProtocol.TOPICS_KEY_NAME: String
added: static field ConsumerProtocol.TOPIC_ASSIGNMENT_V0: Schema
added: static field ConsumerProtocol.TOPIC_KEY_NAME: String
added: static field ConsumerProtocol.TOPIC_PARTITIONS_KEY_NAME: String
added: static field ConsumerProtocol.USER_DATA_KEY_NAME: String
added: static field ConsumerProtocol.VERSION_KEY_NAME: String
added: static field SendFailedException.INSTANCE: SendFailedException
added: static method AbstractPartitionAssignor.put(Map, Object, Object): void
added: static method ConsumerProtocol.deserializeAssignment(ByteBuffer): PartitionAssignor.Assignment
added: static method ConsumerProtocol.deserializeSubscription(ByteBuffer): PartitionAssignor.Subscription
added: static method ConsumerProtocol.serializeAssignment(PartitionAssignor.Assignment): ByteBuffer
added: static method ConsumerProtocol.serializeSubscription(PartitionAssignor.Subscription): ByteBuffer
added: static method RequestFuture.coordinatorNotAvailable(): RequestFuture
added: static method RequestFuture.failure(RuntimeException): RequestFuture
added: static method RequestFuture.leaderNotAvailable(): RequestFuture
added: static method RequestFuture.noBrokersAvailable(): RequestFuture
added: static method RequestFuture.staleMetadata(): RequestFuture
added: static method RequestFuture.voidSuccess(): RequestFuture

changed: ctor MockProducer() → ctor MockProducer(Cluster, boolean, Partitioner, Serializer, Serializer)
changed: ctor MockProducer(Cluster, boolean) → ctor MockProducer(boolean, Partitioner, Serializer, Serializer)
changed: ctor MockProducer(boolean) → ctor MockProducer(boolean, Serializer, Serializer)
added: interface Partitioner extends Configurable
added: method KafkaProducer.close(long, TimeUnit): void
added: method KafkaProducer.flush(): void
added: method MockProducer.close(long, TimeUnit): void
added: method MockProducer.flush(): void
added: method Partitioner.close(): void
added: method Partitioner.partition(String, Object, byte[], Object, byte[], Cluster): int
added: method Producer.close(long, TimeUnit): void
added: method Producer.flush(): void
added: method ProducerRecord.equals(Object): boolean
added: method ProducerRecord.hashCode(): int
added: static field ProducerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG: String
added: static field ProducerConfig.KEY_SERIALIZER_CLASS_DOC: String
added: static field ProducerConfig.MAX_BLOCK_MS_CONFIG: String
added: static field ProducerConfig.PARTITIONER_CLASS_CONFIG: String
added: static field ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG: String
added: static field ProducerConfig.VALUE_SERIALIZER_CLASS_DOC: String
added: static method ProducerConfig.addSerializerToConfig(Map, Serializer, Serializer): Map
added: static method ProducerConfig.addSerializerToConfig(Properties, Serializer, Serializer): Properties

removed: class Partitioner
removed: ctor Metadata()
removed: ctor Metadata(long, long)
removed: ctor Partitioner()
removed: final class Metadata
removed: method Metadata.add(String): void
removed: method Metadata.awaitUpdate(int, long): void
removed: method Metadata.failedUpdate(long): void
removed: method Metadata.fetch(): Cluster
removed: method Metadata.lastUpdate(): long
removed: method Metadata.refreshBackoff(): long
removed: method Metadata.requestUpdate(): int
removed: method Metadata.timeToNextUpdate(long): long
removed: method Metadata.topics(): Set
removed: method Metadata.update(Cluster, long): void
removed: method Partitioner.partition(ProducerRecord, Cluster): int
changed: ctor BufferPool(long, int, boolean, Metrics, Time, String, Map) → ctor BufferPool(long, int, Metrics, Time, String, Map)
changed: ctor RecordAccumulator(int, long, long, long, boolean, Metrics, Time, Map) → ctor RecordAccumulator(int, long, CompressionType, long, long, Metrics, Time, Map)
changed: ctor Sender(KafkaClient, Metadata, RecordAccumulator, int, short, int, int, Metrics, Time, String) → ctor Sender(KafkaClient, Metadata, RecordAccumulator, int, short, int, Metrics, Time, String, int)
changed: method BufferPool.allocate(int): ByteBuffer → method BufferPool.allocate(int, long): ByteBuffer
changed: method RecordAccumulator.append(TopicPartition, byte[], byte[], CompressionType, Callback): RecordAccumulator.RecordAppendResult → method RecordAccumulator.append(TopicPartition, byte[], byte[], Callback, long): RecordAccumulator.RecordAppendResult
changed: method RecordBatch.tryAppend(byte[], byte[], Callback): FutureRecordMetadata → method RecordBatch.tryAppend(byte[], byte[], Callback, long): FutureRecordMetadata
added: class DefaultPartitioner implements Partitioner
added: ctor DefaultPartitioner()
added: field RecordBatch.lastAppendTime: long
added: field RecordBatch.produceFuture: ProduceRequestResult
added: method DefaultPartitioner.close(): void
added: method DefaultPartitioner.configure(Map): void
added: method DefaultPartitioner.partition(String, Object, byte[], Object, byte[], Cluster): int
added: method RecordAccumulator.abortExpiredBatches(int, Cluster, long): List
added: method RecordAccumulator.abortIncompleteBatches(): void
added: method RecordAccumulator.awaitFlushCompletion(): void
added: method RecordAccumulator.beginFlush(): void
added: method RecordBatch.inRetry(): boolean
added: method RecordBatch.maybeExpire(int, long, long): boolean
added: method RecordBatch.setRetry(): void
added: method Sender.forceClose(): void

removed: class ProducerPerformance
removed: ctor ProducerPerformance()
removed: static method ProducerPerformance.main(String[]): void

changed: ctor Cluster(Collection, Collection) → ctor Cluster(Collection, Collection, Set)
changed: final class TopicPartition → final class TopicPartition implements Serializable
added: method Cluster.nodeById(int): Node
added: method Cluster.partitionCountForTopic(String): Integer
added: method Cluster.unauthorizedTopics(): Set
added: method Node.idString(): String
added: static method Node.noNode(): Node

added: @interface InterfaceStability.Evolving
added: @interface InterfaceStability.Stable
added: @interface InterfaceStability.Unstable
added: class InterfaceStability
added: ctor InterfaceStability()

added: class LRUCache implements Cache
added: class SynchronizedCache implements Cache
added: ctor LRUCache(int)
added: ctor SynchronizedCache(Cache)
added: interface Cache
added: method Cache.get(Object): Object
added: method Cache.put(Object, Object): void
added: method Cache.remove(Object): boolean
added: method Cache.size(): long
added: method LRUCache.get(Object): Object
added: method LRUCache.put(Object, Object): void
added: method LRUCache.remove(Object): boolean
added: method LRUCache.size(): long
added: method SynchronizedCache.get(Object): Object
added: method SynchronizedCache.put(Object, Object): void
added: method SynchronizedCache.remove(Object): boolean
added: method SynchronizedCache.size(): long

removed: method ConfigDef.define(String, ConfigDef.Type, ConfigDef.Validator, ConfigDef.Importance, String): ConfigDef
changed: method AbstractConfig.getDouble(String): double → method AbstractConfig.getDouble(String): Double
changed: method AbstractConfig.getInt(String): int → method AbstractConfig.getInt(String): Integer
changed: method AbstractConfig.getLong(String): long → method AbstractConfig.getLong(String): Long
changed: static method ConfigDef.ValidString.in(List): ConfigDef.ValidString → static method ConfigDef.ValidString.in(String[]): ConfigDef.ValidString
added: class SaslConfigs
added: class SslConfigs
added: ctor AbstractConfig(ConfigDef, Map, Boolean)
added: ctor SaslConfigs()
added: ctor SslConfigs()
added: method AbstractConfig.equals(Object): boolean
added: method AbstractConfig.getPassword(String): Password
added: method AbstractConfig.getShort(String): Short
added: method AbstractConfig.hashCode(): int
added: method AbstractConfig.ignore(String): void
added: method AbstractConfig.originalsStrings(): Map
added: method AbstractConfig.originalsWithPrefix(String): Map
added: method AbstractConfig.values(): Map
added: method ConfigDef.names(): Set
added: method ConfigDef.withClientSaslSupport(): ConfigDef
added: method ConfigDef.withClientSslSupport(): ConfigDef
added: static field ConfigDef.Type.PASSWORD: ConfigDef.Type
added: static field ConfigDef.Type.SHORT: ConfigDef.Type
added: static field SaslConfigs.DEFAULT_KERBEROS_KINIT_CMD: String
added: static field SaslConfigs.DEFAULT_KERBEROS_MIN_TIME_BEFORE_RELOGIN: long
added: static field SaslConfigs.DEFAULT_KERBEROS_TICKET_RENEW_JITTER: double
added: static field SaslConfigs.DEFAULT_KERBEROS_TICKET_RENEW_WINDOW_FACTOR: double
added: static field SaslConfigs.DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES: List
added: static field SaslConfigs.SASL_KERBEROS_KINIT_CMD: String
added: static field SaslConfigs.SASL_KERBEROS_KINIT_CMD_DOC: String
added: static field SaslConfigs.SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN: String
added: static field SaslConfigs.SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC: String
added: static field SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES: String
added: static field SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_DOC: String
added: static field SaslConfigs.SASL_KERBEROS_SERVICE_NAME: String
added: static field SaslConfigs.SASL_KERBEROS_SERVICE_NAME_DOC: String
added: static field SaslConfigs.SASL_KERBEROS_TICKET_RENEW_JITTER: String
added: static field SaslConfigs.SASL_KERBEROS_TICKET_RENEW_JITTER_DOC: String
added: static field SaslConfigs.SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR: String
added: static field SaslConfigs.SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC: String
added: static field SslConfigs.DEFAULT_PRINCIPAL_BUILDER_CLASS: String
added: static field SslConfigs.DEFAULT_SSL_ENABLED_PROTOCOLS: String
added: static field SslConfigs.DEFAULT_SSL_KEYMANGER_ALGORITHM: String
added: static field SslConfigs.DEFAULT_SSL_KEYSTORE_TYPE: String
added: static field SslConfigs.DEFAULT_SSL_PROTOCOL: String
added: static field SslConfigs.DEFAULT_SSL_TRUSTMANAGER_ALGORITHM: String
added: static field SslConfigs.DEFAULT_SSL_TRUSTSTORE_TYPE: String
added: static field SslConfigs.PRINCIPAL_BUILDER_CLASS_CONFIG: String
added: static field SslConfigs.PRINCIPAL_BUILDER_CLASS_DOC: String
added: static field SslConfigs.SSL_CIPHER_SUITES_CONFIG: String
added: static field SslConfigs.SSL_CIPHER_SUITES_DOC: String
added: static field SslConfigs.SSL_CLIENT_AUTH_CONFIG: String
added: static field SslConfigs.SSL_CLIENT_AUTH_DOC: String
added: static field SslConfigs.SSL_ENABLED_PROTOCOLS_CONFIG: String
added: static field SslConfigs.SSL_ENABLED_PROTOCOLS_DOC: String
added: static field SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG: String
added: static field SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_DOC: String
added: static field SslConfigs.SSL_KEYMANAGER_ALGORITHM_CONFIG: String
added: static field SslConfigs.SSL_KEYMANAGER_ALGORITHM_DOC: String
added: static field SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG: String
added: static field SslConfigs.SSL_KEYSTORE_LOCATION_DOC: String
added: static field SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG: String
added: static field SslConfigs.SSL_KEYSTORE_PASSWORD_DOC: String
added: static field SslConfigs.SSL_KEYSTORE_TYPE_CONFIG: String
added: static field SslConfigs.SSL_KEYSTORE_TYPE_DOC: String
added: static field SslConfigs.SSL_KEY_PASSWORD_CONFIG: String
added: static field SslConfigs.SSL_KEY_PASSWORD_DOC: String
added: static field SslConfigs.SSL_PROTOCOL_CONFIG: String
added: static field SslConfigs.SSL_PROTOCOL_DOC: String
added: static field SslConfigs.SSL_PROVIDER_CONFIG: String
added: static field SslConfigs.SSL_PROVIDER_DOC: String
added: static field SslConfigs.SSL_TRUSTMANAGER_ALGORITHM_CONFIG: String
added: static field SslConfigs.SSL_TRUSTMANAGER_ALGORITHM_DOC: String
added: static field SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG: String
added: static field SslConfigs.SSL_TRUSTSTORE_LOCATION_DOC: String
added: static field SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG: String
added: static field SslConfigs.SSL_TRUSTSTORE_PASSWORD_DOC: String
added: static field SslConfigs.SSL_TRUSTSTORE_TYPE_CONFIG: String
added: static field SslConfigs.SSL_TRUSTSTORE_TYPE_DOC: String
added: static method SaslConfigs.addClientSaslSupport(ConfigDef): void
added: static method SslConfigs.addClientSslSupport(ConfigDef): void

added: class Password
added: ctor Password(String)
added: method Password.equals(Object): boolean
added: method Password.hashCode(): int
added: method Password.toString(): String
added: method Password.value(): String
added: static field Password.HIDDEN: String

removed: class OffsetOutOfRangeException extends RetriableException
removed: ctor NotEnoughReplicasAfterAppendException()
removed: ctor NotEnoughReplicasAfterAppendException(String, Throwable)
removed: ctor NotEnoughReplicasAfterAppendException(Throwable)
removed: ctor OffsetOutOfRangeException()
removed: ctor OffsetOutOfRangeException(String)
removed: ctor OffsetOutOfRangeException(String, Throwable)
removed: ctor OffsetOutOfRangeException(Throwable)
changed: abstract class ApiException extends KafkaException → class ApiException extends KafkaException
changed: class UnknownTopicOrPartitionException extends RetriableException → class UnknownTopicOrPartitionException extends InvalidMetadataException
added: class AuthorizationException extends ApiException
added: class BrokerNotAvailableException extends ApiException
added: class ControllerMovedException extends ApiException
added: class DisconnectException extends RetriableException
added: class GroupAuthorizationException extends AuthorizationException
added: class GroupCoordinatorNotAvailableException extends RetriableException
added: class GroupLoadInProgressException extends RetriableException
added: class IllegalGenerationException extends ApiException
added: class InterruptException extends KafkaException
added: class InvalidRequiredAcksException extends ApiException
added: class NotCoordinatorForGroupException extends RetriableException
added: class RebalanceInProgressException extends ApiException
added: class TopicAuthorizationException extends AuthorizationException
added: class UnknownMemberIdException extends ApiException
added: class WakeupException extends KafkaException
added: ctor AuthorizationException(String)
added: ctor BrokerNotAvailableException(String)
added: ctor BrokerNotAvailableException(String, Throwable)
added: ctor ControllerMovedException(String)
added: ctor ControllerMovedException(String, Throwable)
added: ctor DisconnectException()
added: ctor DisconnectException(String)
added: ctor DisconnectException(String, Throwable)
added: ctor DisconnectException(Throwable)
added: ctor GroupAuthorizationException(String)
added: ctor GroupCoordinatorNotAvailableException()
added: ctor GroupCoordinatorNotAvailableException(String)
added: ctor GroupCoordinatorNotAvailableException(String, Throwable)
added: ctor GroupCoordinatorNotAvailableException(Throwable)
added: ctor GroupLoadInProgressException()
added: ctor GroupLoadInProgressException(String)
added: ctor GroupLoadInProgressException(String, Throwable)
added: ctor GroupLoadInProgressException(Throwable)
added: ctor IllegalGenerationException()
added: ctor IllegalGenerationException(String)
added: ctor IllegalGenerationException(String, Throwable)
added: ctor IllegalGenerationException(Throwable)
added: ctor InterruptException(InterruptedException)
added: ctor InterruptException(String)
added: ctor InterruptException(String, InterruptedException)
added: ctor InvalidRequiredAcksException(String)
added: ctor NotCoordinatorForGroupException()
added: ctor NotCoordinatorForGroupException(String)
added: ctor NotCoordinatorForGroupException(String, Throwable)
added: ctor NotCoordinatorForGroupException(Throwable)
added: ctor RebalanceInProgressException()
added: ctor RebalanceInProgressException(String)
added: ctor RebalanceInProgressException(String, Throwable)
added: ctor RebalanceInProgressException(Throwable)
added: ctor RecordTooLargeException(String, Map)
added: ctor TopicAuthorizationException(Set)
added: ctor TopicAuthorizationException(String)
added: ctor UnknownMemberIdException()
added: ctor UnknownMemberIdException(String)
added: ctor UnknownMemberIdException(String, Throwable)
added: ctor UnknownMemberIdException(Throwable)
added: ctor WakeupException()
added: method GroupAuthorizationException.groupId(): String
added: method RecordTooLargeException.recordTooLargePartitions(): Map
added: method TopicAuthorizationException.unauthorizedTopics(): Set
added: static field DisconnectException.INSTANCE: DisconnectException

removed: ctor KafkaLZ4BlockInputStream(InputStream)
removed: ctor KafkaLZ4BlockOutputStream(OutputStream)
removed: ctor KafkaLZ4BlockOutputStream(OutputStream, int)
removed: ctor KafkaLZ4BlockOutputStream(OutputStream, int, boolean)
removed: ctor KafkaLZ4BlockOutputStream.BD()
removed: ctor KafkaLZ4BlockOutputStream.BD(int)
removed: ctor KafkaLZ4BlockOutputStream.FLG()
removed: ctor KafkaLZ4BlockOutputStream.FLG(boolean)
removed: final class KafkaLZ4BlockInputStream extends FilterInputStream
removed: final class KafkaLZ4BlockOutputStream extends FilterOutputStream
removed: method KafkaLZ4BlockInputStream.available(): int
removed: method KafkaLZ4BlockInputStream.close(): void
removed: method KafkaLZ4BlockInputStream.mark(int): void
removed: method KafkaLZ4BlockInputStream.markSupported(): boolean
removed: method KafkaLZ4BlockInputStream.read(): int
removed: method KafkaLZ4BlockInputStream.read(byte[], int, int): int
removed: method KafkaLZ4BlockInputStream.reset(): void
removed: method KafkaLZ4BlockInputStream.skip(long): long
removed: method KafkaLZ4BlockOutputStream.BD.getBlockMaximumSize(): int
removed: method KafkaLZ4BlockOutputStream.BD.toByte(): byte
removed: method KafkaLZ4BlockOutputStream.FLG.getVersion(): int
removed: method KafkaLZ4BlockOutputStream.FLG.isBlockChecksumSet(): boolean
removed: method KafkaLZ4BlockOutputStream.FLG.isBlockIndependenceSet(): boolean
removed: method KafkaLZ4BlockOutputStream.FLG.isContentChecksumSet(): boolean
removed: method KafkaLZ4BlockOutputStream.FLG.isContentSizeSet(): boolean
removed: method KafkaLZ4BlockOutputStream.FLG.isPresetDictionarySet(): boolean
removed: method KafkaLZ4BlockOutputStream.FLG.toByte(): byte
removed: method KafkaLZ4BlockOutputStream.close(): void
removed: method KafkaLZ4BlockOutputStream.flush(): void
removed: method KafkaLZ4BlockOutputStream.write(byte[], int, int): void
removed: method KafkaLZ4BlockOutputStream.write(int): void
removed: static class KafkaLZ4BlockOutputStream.BD
removed: static class KafkaLZ4BlockOutputStream.FLG
removed: static field KafkaLZ4BlockInputStream.BLOCK_HASH_MISMATCH: String
removed: static field KafkaLZ4BlockInputStream.DESCRIPTOR_HASH_MISMATCH: String
removed: static field KafkaLZ4BlockInputStream.NOT_SUPPORTED: String
removed: static field KafkaLZ4BlockInputStream.PREMATURE_EOS: String
removed: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_1MB: int
removed: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_256KB: int
removed: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_4MB: int
removed: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_64KB: int
removed: static field KafkaLZ4BlockOutputStream.CLOSED_STREAM: String
removed: static field KafkaLZ4BlockOutputStream.LZ4_FRAME_INCOMPRESSIBLE_MASK: int
removed: static field KafkaLZ4BlockOutputStream.LZ4_MAX_HEADER_LENGTH: int
removed: static field KafkaLZ4BlockOutputStream.MAGIC: int
removed: static method KafkaLZ4BlockOutputStream.BD.fromByte(byte): KafkaLZ4BlockOutputStream.BD
removed: static method KafkaLZ4BlockOutputStream.FLG.fromByte(byte): KafkaLZ4BlockOutputStream.FLG

removed: static method Quota.lessThan(double): Quota
removed: static method Quota.moreThan(double): Quota
changed: class Metrics → class Metrics implements Closeable
added: ctor Metrics(MetricConfig, List, Time, boolean)
added: method JmxReporter.metricRemoval(KafkaMetric): void
added: method KafkaMetric.measurable(): Measurable
added: method Metrics.removeMetric(MetricName): KafkaMetric
added: method Metrics.removeSensor(String): void
added: method Metrics.sensor(String, MetricConfig, long, Sensor[]): Sensor
added: method MetricsReporter.metricRemoval(KafkaMetric): void
added: method Quota.equals(Object): boolean
added: method Quota.hashCode(): int
added: method Sensor.hasExpired(): boolean
added: static method Quota.lowerBound(double): Quota
added: static method Quota.upperBound(double): Quota

added: method Rate.windowSize(MetricConfig, long): long

removed: method ByteBufferReceive.reify(): ByteBuffer[]
removed: method ByteBufferSend.reify(): ByteBuffer[]
removed: method ByteBufferSend.remaining(): int
removed: method NetworkReceive.reify(): ByteBuffer[]
removed: method Receive.reify(): ByteBuffer[]
removed: method Selectable.disconnect(int): void
removed: method Selector.disconnect(int): void
removed: method Send.reify(): ByteBuffer[]
removed: method Send.remaining(): int
changed: ctor ByteBufferReceive(int, ByteBuffer[]) → ctor ByteBufferReceive(String, ByteBuffer[])
changed: ctor ByteBufferSend(int, ByteBuffer[]) → ctor ByteBufferSend(String, ByteBuffer[])
changed: ctor NetworkReceive(int) → ctor NetworkReceive()
changed: ctor NetworkReceive(int, ByteBuffer) → ctor NetworkReceive(String)
changed: ctor NetworkSend(int, ByteBuffer[]) → ctor NetworkSend(String, ByteBuffer[])
changed: ctor Selector(Metrics, Time, String, Map) → ctor Selector(int, long, Metrics, Time, String, Map, boolean, ChannelBuilder)
changed: method ByteBufferReceive.source(): int → method ByteBufferReceive.source(): String
changed: method ByteBufferSend.destination(): int → method ByteBufferSend.destination(): String
changed: method ByteBufferSend.size(): int → method ByteBufferSend.size(): long
changed: method NetworkReceive.source(): int → method NetworkReceive.source(): String
changed: method Receive.source(): int → method Receive.source(): String
changed: method Selectable.connect(int, InetSocketAddress, int, int): void → method Selectable.connect(String, InetSocketAddress, int, int): void
changed: method Selectable.poll(long, List): void → method Selectable.poll(long): void
changed: method Selector.connect(int, InetSocketAddress, int, int): void → method Selector.connect(String, InetSocketAddress, int, int): void
changed: method Selector.poll(long, List): void → method Selector.poll(long): void
changed: method Send.destination(): int → method Send.destination(): String
added: class ChannelBuilders
added: class DefaultAuthenticator implements Authenticator
added: class InvalidReceiveException extends KafkaException
added: class KafkaChannel
added: class MultiSend implements Send
added: class PlaintextChannelBuilder implements ChannelBuilder
added: class PlaintextTransportLayer implements TransportLayer
added: class SaslChannelBuilder implements ChannelBuilder
added: class SslChannelBuilder implements ChannelBuilder
added: class SslTransportLayer implements TransportLayer
added: ctor DefaultAuthenticator()
added: ctor InvalidReceiveException(String)
added: ctor InvalidReceiveException(String, Throwable)
added: ctor KafkaChannel(String, TransportLayer, Authenticator, int)
added: ctor MultiSend(String, List)
added: ctor NetworkReceive(String, ByteBuffer)
added: ctor NetworkReceive(int, String)
added: ctor PlaintextChannelBuilder()
added: ctor PlaintextTransportLayer(SelectionKey)
added: ctor SaslChannelBuilder(Mode, LoginType, SecurityProtocol)
added: ctor Selector(long, Metrics, Time, String, Map, ChannelBuilder)
added: ctor SslChannelBuilder(Mode)
added: enum LoginType
added: enum Mode
added: interface Authenticator
added: interface ChannelBuilder
added: interface TransportLayer extends ScatteringByteChannel, GatheringByteChannel
added: method Authenticator.authenticate(): void
added: method Authenticator.close(): void
added: method Authenticator.complete(): boolean
added: method Authenticator.configure(TransportLayer, PrincipalBuilder, Map): void
added: method Authenticator.principal(): Principal
added: method ChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel
added: method ChannelBuilder.close(): void
added: method ChannelBuilder.configure(Map): void
added: method DefaultAuthenticator.authenticate(): void
added: method DefaultAuthenticator.close(): void
added: method DefaultAuthenticator.complete(): boolean
added: method DefaultAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
added: method DefaultAuthenticator.principal(): Principal
added: method KafkaChannel.close(): void
added: method KafkaChannel.disconnect(): void
added: method KafkaChannel.finishConnect(): void
added: method KafkaChannel.hasSend(): boolean
added: method KafkaChannel.id(): String
added: method KafkaChannel.isConnected(): boolean
added: method KafkaChannel.isMute(): boolean
added: method KafkaChannel.mute(): void
added: method KafkaChannel.prepare(): void
added: method KafkaChannel.principal(): Principal
added: method KafkaChannel.read(): NetworkReceive
added: method KafkaChannel.ready(): boolean
added: method KafkaChannel.setSend(Send): void
added: method KafkaChannel.socketAddress(): InetAddress
added: method KafkaChannel.socketDescription(): String
added: method KafkaChannel.unmute(): void
added: method KafkaChannel.write(): Send
added: method LoginType.contextName(): String
added: method MultiSend.completed(): boolean
added: method MultiSend.destination(): String
added: method MultiSend.size(): long
added: method MultiSend.writeTo(GatheringByteChannel): long
added: method NetworkReceive.readFromReadableChannel(ReadableByteChannel): long
added: method PlaintextChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel
added: method PlaintextChannelBuilder.close(): void
added: method PlaintextChannelBuilder.configure(Map): void
added: method PlaintextTransportLayer.addInterestOps(int): void
added: method PlaintextTransportLayer.close(): void
added: method PlaintextTransportLayer.disconnect(): void
added: method PlaintextTransportLayer.finishConnect(): void
added: method PlaintextTransportLayer.handshake(): void
added: method PlaintextTransportLayer.hasPendingWrites(): boolean
added: method PlaintextTransportLayer.isConnected(): boolean
added: method PlaintextTransportLayer.isMute(): boolean
added: method PlaintextTransportLayer.isOpen(): boolean
added: method PlaintextTransportLayer.peerPrincipal(): Principal
added: method PlaintextTransportLayer.read(ByteBuffer): int
added: method PlaintextTransportLayer.read(ByteBuffer[]): long
added: method PlaintextTransportLayer.read(ByteBuffer[], int, int): long
added: method PlaintextTransportLayer.ready(): boolean
added: method PlaintextTransportLayer.removeInterestOps(int): void
added: method PlaintextTransportLayer.socketChannel(): SocketChannel
added: method PlaintextTransportLayer.transferFrom(FileChannel, long, long): long
added: method PlaintextTransportLayer.write(ByteBuffer): int
added: method PlaintextTransportLayer.write(ByteBuffer[]): long
added: method PlaintextTransportLayer.write(ByteBuffer[], int, int): long
added: method SaslChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel
added: method SaslChannelBuilder.buildTransportLayer(String, SelectionKey, SocketChannel): TransportLayer
added: method SaslChannelBuilder.close(): void
added: method SaslChannelBuilder.configure(Map): void
added: method Selectable.close(String): void
added: method Selectable.isChannelReady(String): boolean
added: method Selectable.mute(String): void
added: method Selectable.muteAll(): void
added: method Selectable.send(Send): void
added: method Selectable.unmute(String): void
added: method Selectable.unmuteAll(): void
added: method Selector.channel(String): KafkaChannel
added: method Selector.channels(): List
added: method Selector.close(String): void
added: method Selector.isChannelReady(String): boolean
added: method Selector.mute(String): void
added: method Selector.muteAll(): void
added: method Selector.register(String, SocketChannel): void
added: method Selector.send(Send): void
added: method Selector.unmute(String): void
added: method Selector.unmuteAll(): void
added: method Send.size(): long
added: method SslChannelBuilder.buildChannel(String, SelectionKey, int): KafkaChannel
added: method SslChannelBuilder.buildTransportLayer(SslFactory, String, SelectionKey): SslTransportLayer
added: method SslChannelBuilder.close(): void
added: method SslChannelBuilder.configure(Map): void
added: method SslTransportLayer.addInterestOps(int): void
added: method SslTransportLayer.applicationBufferSize(): int
added: method SslTransportLayer.close(): void
added: method SslTransportLayer.delegatedTask(): Runnable
added: method SslTransportLayer.disconnect(): void
added: method SslTransportLayer.finishConnect(): void
added: method SslTransportLayer.handshake(): void
added: method SslTransportLayer.hasPendingWrites(): boolean
added: method SslTransportLayer.isConnected(): boolean
added: method SslTransportLayer.isMute(): boolean
added: method SslTransportLayer.isOpen(): boolean
added: method SslTransportLayer.netReadBuffer(): ByteBuffer
added: method SslTransportLayer.netReadBufferSize(): int
added: method SslTransportLayer.netWriteBufferSize(): int
added: method SslTransportLayer.peerPrincipal(): Principal
added: method SslTransportLayer.read(ByteBuffer): int
added: method SslTransportLayer.read(ByteBuffer[]): long
added: method SslTransportLayer.read(ByteBuffer[], int, int): long
added: method SslTransportLayer.ready(): boolean
added: method SslTransportLayer.removeInterestOps(int): void
added: method SslTransportLayer.socketChannel(): SocketChannel
added: method SslTransportLayer.sslSession(): SSLSession
added: method SslTransportLayer.startHandshake(): void
added: method SslTransportLayer.transferFrom(FileChannel, long, long): long
added: method SslTransportLayer.write(ByteBuffer): int
added: method SslTransportLayer.write(ByteBuffer[]): long
added: method SslTransportLayer.write(ByteBuffer[], int, int): long
added: method TransportLayer.addInterestOps(int): void
added: method TransportLayer.disconnect(): void
added: method TransportLayer.finishConnect(): void
added: method TransportLayer.handshake(): void
added: method TransportLayer.hasPendingWrites(): boolean
added: method TransportLayer.isConnected(): boolean
added: method TransportLayer.isMute(): boolean
added: method TransportLayer.peerPrincipal(): Principal
added: method TransportLayer.ready(): boolean
added: method TransportLayer.removeInterestOps(int): void
added: method TransportLayer.socketChannel(): SocketChannel
added: method TransportLayer.transferFrom(FileChannel, long, long): long
added: static field LoginType.CLIENT: LoginType
added: static field LoginType.SERVER: LoginType
added: static field Mode.CLIENT: Mode
added: static field Mode.SERVER: Mode
added: static field NetworkReceive.UNKNOWN_SOURCE: String
added: static field NetworkReceive.UNLIMITED: int
added: static field Selectable.USE_DEFAULT_BUFFER_SIZE: int
added: static method ChannelBuilders.create(SecurityProtocol, Mode, LoginType, Map): ChannelBuilder
added: static method LoginType.valueOf(String): LoginType
added: static method LoginType.values(): LoginType[]
added: static method Mode.valueOf(String): Mode
added: static method Mode.values(): Mode[]
added: static method SslTransportLayer.create(String, SelectionKey, SSLEngine): SslTransportLayer

removed: static field ApiKeys.CONSUMER_METADATA: ApiKeys
removed: static field Protocol.CONSUMER_METADATA_REQUEST: Schema[]
removed: static field Protocol.CONSUMER_METADATA_REQUEST_V0: Schema
removed: static field Protocol.CONSUMER_METADATA_RESPONSE: Schema[]
removed: static field Protocol.CONSUMER_METADATA_RESPONSE_V0: Schema
removed: static field Protocol.JOIN_GROUP_RESPONSE_TOPIC_V0: Schema
added: enum SecurityProtocol
added: field SecurityProtocol.id: short
added: field SecurityProtocol.name: String
added: static field ApiKeys.CONTROLLED_SHUTDOWN_KEY: ApiKeys
added: static field ApiKeys.DESCRIBE_GROUPS: ApiKeys
added: static field ApiKeys.GROUP_COORDINATOR: ApiKeys
added: static field ApiKeys.LEAVE_GROUP: ApiKeys
added: static field ApiKeys.LIST_GROUPS: ApiKeys
added: static field ApiKeys.SYNC_GROUP: ApiKeys
added: static field ApiKeys.UPDATE_METADATA_KEY: ApiKeys
added: static field Errors.BROKER_NOT_AVAILABLE: Errors
added: static field Errors.CLUSTER_AUTHORIZATION_FAILED: Errors
added: static field Errors.GROUP_AUTHORIZATION_FAILED: Errors
added: static field Errors.GROUP_COORDINATOR_NOT_AVAILABLE: Errors
added: static field Errors.GROUP_LOAD_IN_PROGRESS: Errors
added: static field Errors.ILLEGAL_GENERATION: Errors
added: static field Errors.INCONSISTENT_GROUP_PROTOCOL: Errors
added: static field Errors.INVALID_COMMIT_OFFSET_SIZE: Errors
added: static field Errors.INVALID_GROUP_ID: Errors
added: static field Errors.INVALID_REQUIRED_ACKS: Errors
added: static field Errors.INVALID_SESSION_TIMEOUT: Errors
added: static field Errors.NOT_COORDINATOR_FOR_GROUP: Errors
added: static field Errors.REBALANCE_IN_PROGRESS: Errors
added: static field Errors.REPLICA_NOT_AVAILABLE: Errors
added: static field Errors.STALE_CONTROLLER_EPOCH: Errors
added: static field Errors.TOPIC_AUTHORIZATION_FAILED: Errors
added: static field Errors.UNKNOWN_MEMBER_ID: Errors
added: static field Protocol.CONTROLLED_SHUTDOWN_PARTITION_V1: Schema
added: static field Protocol.CONTROLLED_SHUTDOWN_REQUEST: Schema[]
added: static field Protocol.CONTROLLED_SHUTDOWN_REQUEST_V1: Schema
added: static field Protocol.CONTROLLED_SHUTDOWN_RESPONSE: Schema[]
added: static field Protocol.CONTROLLED_SHUTDOWN_RESPONSE_V1: Schema
added: static field Protocol.DESCRIBE_GROUPS_REQUEST: Schema[]
added: static field Protocol.DESCRIBE_GROUPS_REQUEST_V0: Schema
added: static field Protocol.DESCRIBE_GROUPS_RESPONSE: Schema[]
added: static field Protocol.DESCRIBE_GROUPS_RESPONSE_GROUP_METADATA_V0: Schema
added: static field Protocol.DESCRIBE_GROUPS_RESPONSE_MEMBER_V0: Schema
added: static field Protocol.DESCRIBE_GROUPS_RESPONSE_V0: Schema
added: static field Protocol.FETCH_REQUEST_V1: Schema
added: static field Protocol.FETCH_RESPONSE_V1: Schema
added: static field Protocol.GROUP_COORDINATOR_REQUEST: Schema[]
added: static field Protocol.GROUP_COORDINATOR_REQUEST_V0: Schema
added: static field Protocol.GROUP_COORDINATOR_RESPONSE: Schema[]
added: static field Protocol.GROUP_COORDINATOR_RESPONSE_V0: Schema
added: static field Protocol.JOIN_GROUP_REQUEST_PROTOCOL_V0: Schema
added: static field Protocol.JOIN_GROUP_RESPONSE_MEMBER_V0: Schema
added: static field Protocol.LEADER_AND_ISR_REQUEST: Schema[]
added: static field Protocol.LEADER_AND_ISR_REQUEST_LIVE_LEADER_V0: Schema
added: static field Protocol.LEADER_AND_ISR_REQUEST_PARTITION_STATE_V0: Schema
added: static field Protocol.LEADER_AND_ISR_REQUEST_V0: Schema
added: static field Protocol.LEADER_AND_ISR_RESPONSE: Schema[]
added: static field Protocol.LEADER_AND_ISR_RESPONSE_PARTITION_V0: Schema
added: static field Protocol.LEADER_AND_ISR_RESPONSE_V0: Schema
added: static field Protocol.LEAVE_GROUP_REQUEST: Schema[]
added: static field Protocol.LEAVE_GROUP_REQUEST_V0: Schema
added: static field Protocol.LEAVE_GROUP_RESPONSE: Schema[]
added: static field Protocol.LEAVE_GROUP_RESPONSE_V0: Schema
added: static field Protocol.LIST_GROUPS_REQUEST: Schema[]
added: static field Protocol.LIST_GROUPS_REQUEST_V0: Schema
added: static field Protocol.LIST_GROUPS_RESPONSE: Schema[]
added: static field Protocol.LIST_GROUPS_RESPONSE_GROUP_V0: Schema
added: static field Protocol.LIST_GROUPS_RESPONSE_V0: Schema
added: static field Protocol.OFFSET_COMMIT_REQUEST_PARTITION_V2: Schema
added: static field Protocol.OFFSET_COMMIT_REQUEST_TOPIC_V2: Schema
added: static field Protocol.OFFSET_COMMIT_REQUEST_V2: Schema
added: static field Protocol.OFFSET_COMMIT_RESPONSE_V2: Schema
added: static field Protocol.PRODUCE_REQUEST_V1: Schema
added: static field Protocol.PRODUCE_RESPONSE_V1: Schema
added: static field Protocol.STOP_REPLICA_REQUEST: Schema[]
added: static field Protocol.STOP_REPLICA_REQUEST_PARTITION_V0: Schema
added: static field Protocol.STOP_REPLICA_REQUEST_V0: Schema
added: static field Protocol.STOP_REPLICA_RESPONSE: Schema[]
added: static field Protocol.STOP_REPLICA_RESPONSE_PARTITION_V0: Schema
added: static field Protocol.STOP_REPLICA_RESPONSE_V0: Schema
added: static field Protocol.SYNC_GROUP_REQUEST: Schema[]
added: static field Protocol.SYNC_GROUP_REQUEST_MEMBER_V0: Schema
added: static field Protocol.SYNC_GROUP_REQUEST_V0: Schema
added: static field Protocol.SYNC_GROUP_RESPONSE: Schema[]
added: static field Protocol.SYNC_GROUP_RESPONSE_V0: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST: Schema[]
added: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V0: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_BROKER_V1: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_END_POINT_V1: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V0: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_PARTITION_STATE_V1: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_V0: Schema
added: static field Protocol.UPDATE_METADATA_REQUEST_V1: Schema
added: static field Protocol.UPDATE_METADATA_RESPONSE: Schema[]
added: static field Protocol.UPDATE_METADATA_RESPONSE_V0: Schema
added: static field Protocol.UPDATE_METADATA_RESPONSE_V1: Schema
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 field SecurityProtocol.TRACE: SecurityProtocol
added: static method ProtoUtils.parseResponse(int, int, ByteBuffer): Struct
added: static method SecurityProtocol.forId(Short): SecurityProtocol
added: static method SecurityProtocol.getName(int): String
added: static method SecurityProtocol.getNames(): List
added: static method SecurityProtocol.nonTestingValues(): Set
added: static method SecurityProtocol.valueOf(String): SecurityProtocol
added: static method SecurityProtocol.values(): SecurityProtocol[]

added: method Struct.getByte(Field): Byte
added: method Struct.getByte(String): byte
added: method Type.isNullable(): boolean
added: static field Type.NULLABLE_BYTES: Type

removed: method MemoryRecords.capacity(): int
removed: method MemoryRecords.writeTo(GatheringByteChannel): int
removed: method Records.writeTo(GatheringByteChannel): int
removed: static method MemoryRecords.iterableRecords(ByteBuffer): MemoryRecords
added: ctor KafkaLZ4BlockInputStream(InputStream)
added: ctor KafkaLZ4BlockOutputStream(OutputStream)
added: ctor KafkaLZ4BlockOutputStream(OutputStream, int)
added: ctor KafkaLZ4BlockOutputStream(OutputStream, int, boolean)
added: ctor KafkaLZ4BlockOutputStream.BD()
added: ctor KafkaLZ4BlockOutputStream.BD(int)
added: ctor KafkaLZ4BlockOutputStream.FLG()
added: ctor KafkaLZ4BlockOutputStream.FLG(boolean)
added: field Compressor.compressionRate: float
added: final class KafkaLZ4BlockInputStream extends FilterInputStream
added: final class KafkaLZ4BlockOutputStream extends FilterOutputStream
added: method Compressor.numRecordsWritten(): long
added: method KafkaLZ4BlockInputStream.available(): int
added: method KafkaLZ4BlockInputStream.close(): void
added: method KafkaLZ4BlockInputStream.mark(int): void
added: method KafkaLZ4BlockInputStream.markSupported(): boolean
added: method KafkaLZ4BlockInputStream.read(): int
added: method KafkaLZ4BlockInputStream.read(byte[], int, int): int
added: method KafkaLZ4BlockInputStream.reset(): void
added: method KafkaLZ4BlockInputStream.skip(long): long
added: method KafkaLZ4BlockOutputStream.BD.getBlockMaximumSize(): int
added: method KafkaLZ4BlockOutputStream.BD.toByte(): byte
added: method KafkaLZ4BlockOutputStream.FLG.getVersion(): int
added: method KafkaLZ4BlockOutputStream.FLG.isBlockChecksumSet(): boolean
added: method KafkaLZ4BlockOutputStream.FLG.isBlockIndependenceSet(): boolean
added: method KafkaLZ4BlockOutputStream.FLG.isContentChecksumSet(): boolean
added: method KafkaLZ4BlockOutputStream.FLG.isContentSizeSet(): boolean
added: method KafkaLZ4BlockOutputStream.FLG.isPresetDictionarySet(): boolean
added: method KafkaLZ4BlockOutputStream.FLG.toByte(): byte
added: method KafkaLZ4BlockOutputStream.close(): void
added: method KafkaLZ4BlockOutputStream.flush(): void
added: method KafkaLZ4BlockOutputStream.write(byte[], int, int): void
added: method KafkaLZ4BlockOutputStream.write(int): void
added: method LogEntry.size(): int
added: method MemoryRecords.initialCapacity(): int
added: method MemoryRecords.toString(): String
added: static class KafkaLZ4BlockOutputStream.BD
added: static class KafkaLZ4BlockOutputStream.FLG
added: static field KafkaLZ4BlockInputStream.BLOCK_HASH_MISMATCH: String
added: static field KafkaLZ4BlockInputStream.DESCRIPTOR_HASH_MISMATCH: String
added: static field KafkaLZ4BlockInputStream.NOT_SUPPORTED: String
added: static field KafkaLZ4BlockInputStream.PREMATURE_EOS: String
added: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_1MB: int
added: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_256KB: int
added: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_4MB: int
added: static field KafkaLZ4BlockOutputStream.BLOCKSIZE_64KB: int
added: static field KafkaLZ4BlockOutputStream.CLOSED_STREAM: String
added: static field KafkaLZ4BlockOutputStream.LZ4_FRAME_INCOMPRESSIBLE_MASK: int
added: static field KafkaLZ4BlockOutputStream.LZ4_MAX_HEADER_LENGTH: int
added: static field KafkaLZ4BlockOutputStream.MAGIC: int
added: static method KafkaLZ4BlockOutputStream.BD.fromByte(byte): KafkaLZ4BlockOutputStream.BD
added: static method KafkaLZ4BlockOutputStream.FLG.fromByte(byte): KafkaLZ4BlockOutputStream.FLG
added: static method MemoryRecords.readableRecords(ByteBuffer): MemoryRecords

removed: class ConsumerMetadataRequest extends AbstractRequestResponse
removed: class ConsumerMetadataResponse extends AbstractRequestResponse
removed: ctor ConsumerMetadataRequest(String)
removed: ctor ConsumerMetadataRequest(Struct)
removed: ctor ConsumerMetadataResponse(Struct)
removed: ctor ConsumerMetadataResponse(short, Node)
removed: ctor JoinGroupResponse(short, int, String, List)
removed: method ConsumerMetadataRequest.groupId(): String
removed: method ConsumerMetadataResponse.errorCode(): short
removed: method ConsumerMetadataResponse.node(): Node
removed: method HeartbeatRequest.consumerId(): String
removed: method JoinGroupRequest.consumerId(): String
removed: method JoinGroupRequest.strategy(): String
removed: method JoinGroupRequest.topics(): List
removed: method JoinGroupResponse.assignedPartitions(): List
removed: method JoinGroupResponse.consumerId(): String
removed: method OffsetCommitRequest.consumerId(): String
removed: static field ConsumerMetadataRequest.curSchema: Schema
removed: static field FetchRequest.curSchema: Schema
removed: static field FetchResponse.curSchema: Schema
removed: static field HeartbeatRequest.curSchema: Schema
removed: static field JoinGroupRequest.curSchema: Schema
removed: static field JoinGroupResponse.UNKNOWN_CONSUMER_ID: String
removed: static field JoinGroupResponse.curSchema: Schema
removed: static field ListOffsetRequest.curSchema: Schema
removed: static field ListOffsetResponse.curSchema: Schema
removed: static field MetadataRequest.curSchema: Schema
removed: static field OffsetCommitRequest.DEFAULT_CONSUMER_ID: String
removed: static field OffsetCommitRequest.curSchema: Schema
removed: static field OffsetCommitResponse.curSchema: Schema
removed: static field OffsetFetchRequest.DEFAULT_CONSUMER_ID: String
removed: static field OffsetFetchRequest.DEFAULT_GENERATION_ID: int
removed: static field OffsetFetchRequest.curSchema: Schema
removed: static field OffsetFetchResponse.curSchema: Schema
removed: static field ProduceRequest.curSchema: Schema
removed: static method ConsumerMetadataRequest.parse(ByteBuffer): ConsumerMetadataRequest
removed: static method ConsumerMetadataResponse.parse(ByteBuffer): ConsumerMetadataResponse
changed: class FetchRequest extends AbstractRequestResponse → class FetchRequest extends AbstractRequest
changed: class HeartbeatRequest extends AbstractRequestResponse → class HeartbeatRequest extends AbstractRequest
changed: class JoinGroupRequest extends AbstractRequestResponse → class JoinGroupRequest extends AbstractRequest
changed: class ListOffsetRequest extends AbstractRequestResponse → class ListOffsetRequest extends AbstractRequest
changed: class MetadataRequest extends AbstractRequestResponse → class MetadataRequest extends AbstractRequest
changed: class OffsetCommitRequest extends AbstractRequestResponse → class OffsetCommitRequest extends AbstractRequest
changed: class OffsetFetchRequest extends AbstractRequestResponse → class OffsetFetchRequest extends AbstractRequest
changed: class ProduceRequest extends AbstractRequestResponse → class ProduceRequest extends AbstractRequest
changed: ctor JoinGroupRequest(String, int, List, String, String) → ctor JoinGroupRequest(String, int, String, String, List)
changed: ctor JoinGroupResponse(short) → ctor JoinGroupResponse(short, int, String, String, String, Map)
changed: ctor MetadataResponse(Cluster) → ctor MetadataResponse(Cluster, Map)
changed: ctor RequestSend(int, RequestHeader, Struct) → ctor RequestSend(String, RequestHeader, Struct)
added: abstract class AbstractRequest extends AbstractRequestResponse
added: class ControlledShutdownRequest extends AbstractRequest
added: class ControlledShutdownResponse extends AbstractRequestResponse
added: class DescribeGroupsRequest extends AbstractRequest
added: class DescribeGroupsResponse extends AbstractRequestResponse
added: class GroupCoordinatorRequest extends AbstractRequest
added: class GroupCoordinatorResponse extends AbstractRequestResponse
added: class LeaderAndIsrRequest extends AbstractRequest
added: class LeaderAndIsrResponse extends AbstractRequestResponse
added: class LeaveGroupRequest extends AbstractRequest
added: class LeaveGroupResponse extends AbstractRequestResponse
added: class ListGroupsRequest extends AbstractRequest
added: class ListGroupsResponse extends AbstractRequestResponse
added: class ResponseSend extends NetworkSend
added: class StopReplicaRequest extends AbstractRequest
added: class StopReplicaResponse extends AbstractRequestResponse
added: class SyncGroupRequest extends AbstractRequest
added: class SyncGroupResponse extends AbstractRequestResponse
added: class UpdateMetadataRequest extends AbstractRequest
added: class UpdateMetadataResponse extends AbstractRequestResponse
added: ctor AbstractRequest(Struct)
added: ctor ControlledShutdownRequest(Struct)
added: ctor ControlledShutdownRequest(int)
added: ctor ControlledShutdownResponse(Struct)
added: ctor ControlledShutdownResponse(short, Set)
added: ctor DescribeGroupsRequest(List)
added: ctor DescribeGroupsRequest(Struct)
added: ctor DescribeGroupsResponse(Map)
added: ctor DescribeGroupsResponse(Struct)
added: ctor DescribeGroupsResponse.GroupMember(String, String, String, ByteBuffer, ByteBuffer)
added: ctor DescribeGroupsResponse.GroupMetadata(short, String, String, String, List)
added: ctor FetchRequest(int, int, Map)
added: ctor FetchResponse(Map, int)
added: ctor GroupCoordinatorRequest(String)
added: ctor GroupCoordinatorRequest(Struct)
added: ctor GroupCoordinatorResponse(Struct)
added: ctor GroupCoordinatorResponse(short, Node)
added: ctor JoinGroupRequest.ProtocolMetadata(String, ByteBuffer)
added: ctor LeaderAndIsrRequest(Struct)
added: ctor LeaderAndIsrRequest(int, int, Map, Set)
added: ctor LeaderAndIsrRequest.EndPoint(int, String, int)
added: ctor LeaderAndIsrRequest.PartitionState(int, int, int, List, int, Set)
added: ctor LeaderAndIsrResponse(Map)
added: ctor LeaderAndIsrResponse(Struct)
added: ctor LeaderAndIsrResponse(short, Map)
added: ctor LeaveGroupRequest(String, String)
added: ctor LeaveGroupRequest(Struct)
added: ctor LeaveGroupResponse(Struct)
added: ctor LeaveGroupResponse(short)
added: ctor ListGroupsRequest()
added: ctor ListGroupsRequest(Struct)
added: ctor ListGroupsResponse(Struct)
added: ctor ListGroupsResponse(short, List)
added: ctor ListGroupsResponse.Group(String, String)
added: ctor ListOffsetRequest(Map)
added: ctor OffsetCommitRequest(String, int, String, long, Map)
added: ctor ProduceResponse(Map, int)
added: ctor ResponseSend(String, ResponseHeader, AbstractRequestResponse)
added: ctor ResponseSend(String, ResponseHeader, Struct)
added: ctor StopReplicaRequest(Struct)
added: ctor StopReplicaRequest(int, int, boolean, Set)
added: ctor StopReplicaResponse(Map)
added: ctor StopReplicaResponse(Struct)
added: ctor StopReplicaResponse(short, Map)
added: ctor SyncGroupRequest(String, int, String, Map)
added: ctor SyncGroupRequest(Struct)
added: ctor SyncGroupResponse(Struct)
added: ctor SyncGroupResponse(short, ByteBuffer)
added: ctor UpdateMetadataRequest(Struct)
added: ctor UpdateMetadataRequest(int, int, Map, Set)
added: ctor UpdateMetadataRequest(int, int, Set, Map)
added: ctor UpdateMetadataRequest.Broker(int, Map)
added: ctor UpdateMetadataRequest.BrokerEndPoint(int, String, int)
added: ctor UpdateMetadataRequest.EndPoint(String, int)
added: ctor UpdateMetadataRequest.PartitionState(int, int, int, List, int, Set)
added: ctor UpdateMetadataResponse(Struct)
added: ctor UpdateMetadataResponse(short)
added: field LeaderAndIsrRequest.EndPoint.host: String
added: field LeaderAndIsrRequest.EndPoint.id: int
added: field LeaderAndIsrRequest.EndPoint.port: int
added: field LeaderAndIsrRequest.PartitionState.controllerEpoch: int
added: field LeaderAndIsrRequest.PartitionState.isr: List
added: field LeaderAndIsrRequest.PartitionState.leader: int
added: field LeaderAndIsrRequest.PartitionState.leaderEpoch: int
added: field LeaderAndIsrRequest.PartitionState.replicas: Set
added: field LeaderAndIsrRequest.PartitionState.zkVersion: int
added: field UpdateMetadataRequest.Broker.endPoints: Map
added: field UpdateMetadataRequest.Broker.id: int
added: field UpdateMetadataRequest.BrokerEndPoint.host: String
added: field UpdateMetadataRequest.BrokerEndPoint.id: int
added: field UpdateMetadataRequest.BrokerEndPoint.port: int
added: field UpdateMetadataRequest.EndPoint.host: String
added: field UpdateMetadataRequest.EndPoint.port: int
added: field UpdateMetadataRequest.PartitionState.controllerEpoch: int
added: field UpdateMetadataRequest.PartitionState.isr: List
added: field UpdateMetadataRequest.PartitionState.leader: int
added: field UpdateMetadataRequest.PartitionState.leaderEpoch: int
added: field UpdateMetadataRequest.PartitionState.replicas: Set
added: field UpdateMetadataRequest.PartitionState.zkVersion: int
added: method AbstractRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method ControlledShutdownRequest.brokerId(): int
added: method ControlledShutdownRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method ControlledShutdownResponse.errorCode(): short
added: method ControlledShutdownResponse.partitionsRemaining(): Set
added: method DescribeGroupsRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method DescribeGroupsRequest.groupIds(): List
added: method DescribeGroupsResponse.GroupMember.clientHost(): String
added: method DescribeGroupsResponse.GroupMember.clientId(): String
added: method DescribeGroupsResponse.GroupMember.memberAssignment(): ByteBuffer
added: method DescribeGroupsResponse.GroupMember.memberId(): String
added: method DescribeGroupsResponse.GroupMember.memberMetadata(): ByteBuffer
added: method DescribeGroupsResponse.GroupMetadata.errorCode(): short
added: method DescribeGroupsResponse.GroupMetadata.members(): List
added: method DescribeGroupsResponse.GroupMetadata.protocol(): String
added: method DescribeGroupsResponse.GroupMetadata.protocolType(): String
added: method DescribeGroupsResponse.GroupMetadata.state(): String
added: method DescribeGroupsResponse.groups(): Map
added: method FetchRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method FetchResponse.getThrottleTime(): int
added: method GroupCoordinatorRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method GroupCoordinatorRequest.groupId(): String
added: method GroupCoordinatorResponse.errorCode(): short
added: method GroupCoordinatorResponse.node(): Node
added: method HeartbeatRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method HeartbeatRequest.memberId(): String
added: method JoinGroupRequest.ProtocolMetadata.metadata(): ByteBuffer
added: method JoinGroupRequest.ProtocolMetadata.name(): String
added: method JoinGroupRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method JoinGroupRequest.groupProtocols(): List
added: method JoinGroupRequest.memberId(): String
added: method JoinGroupRequest.protocolType(): String
added: method JoinGroupResponse.groupProtocol(): String
added: method JoinGroupResponse.isLeader(): boolean
added: method JoinGroupResponse.leaderId(): String
added: method JoinGroupResponse.memberId(): String
added: method JoinGroupResponse.members(): Map
added: method LeaderAndIsrRequest.controllerEpoch(): int
added: method LeaderAndIsrRequest.controllerId(): int
added: method LeaderAndIsrRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method LeaderAndIsrRequest.liveLeaders(): Set
added: method LeaderAndIsrRequest.partitionStates(): Map
added: method LeaderAndIsrResponse.errorCode(): short
added: method LeaderAndIsrResponse.responses(): Map
added: method LeaveGroupRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method LeaveGroupRequest.groupId(): String
added: method LeaveGroupRequest.memberId(): String
added: method LeaveGroupResponse.errorCode(): short
added: method ListGroupsRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method ListGroupsResponse.Group.groupId(): String
added: method ListGroupsResponse.Group.protocolType(): String
added: method ListGroupsResponse.errorCode(): short
added: method ListGroupsResponse.groups(): List
added: method ListOffsetRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method MetadataRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method MetadataResponse.hasError(String): boolean
added: method OffsetCommitRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method OffsetCommitRequest.memberId(): String
added: method OffsetCommitRequest.retentionTime(): long
added: method OffsetFetchRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method OffsetFetchResponse.PartitionData.hasError(): boolean
added: method ProduceRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method ProduceResponse.getThrottleTime(): int
added: method StopReplicaRequest.controllerEpoch(): int
added: method StopReplicaRequest.controllerId(): int
added: method StopReplicaRequest.deletePartitions(): boolean
added: method StopReplicaRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method StopReplicaRequest.partitions(): Set
added: method StopReplicaResponse.errorCode(): short
added: method StopReplicaResponse.responses(): Map
added: method SyncGroupRequest.generationId(): int
added: method SyncGroupRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method SyncGroupRequest.groupAssignment(): Map
added: method SyncGroupRequest.groupId(): String
added: method SyncGroupRequest.memberId(): String
added: method SyncGroupResponse.errorCode(): short
added: method SyncGroupResponse.memberAssignment(): ByteBuffer
added: method UpdateMetadataRequest.controllerEpoch(): int
added: method UpdateMetadataRequest.controllerId(): int
added: method UpdateMetadataRequest.getErrorResponse(int, Throwable): AbstractRequestResponse
added: method UpdateMetadataRequest.liveBrokers(): Set
added: method UpdateMetadataRequest.partitionStates(): Map
added: method UpdateMetadataResponse.errorCode(): short
added: static class DescribeGroupsResponse.GroupMember
added: static class DescribeGroupsResponse.GroupMetadata
added: static class JoinGroupRequest.ProtocolMetadata
added: static class LeaderAndIsrRequest.PartitionState
added: static class ListGroupsResponse.Group
added: static field DescribeGroupsResponse.UNKNOWN_PROTOCOL: String
added: static field DescribeGroupsResponse.UNKNOWN_PROTOCOL_TYPE: String
added: static field DescribeGroupsResponse.UNKNOWN_STATE: String
added: static field FetchRequest.CONSUMER_REPLICA_ID: int
added: static field FetchResponse.EMPTY_RECORD_SET: ByteBuffer
added: static field FetchResponse.INVALID_HIGHWATERMARK: long
added: static field JoinGroupRequest.UNKNOWN_MEMBER_ID: String
added: static field JoinGroupResponse.UNKNOWN_MEMBER_ID: String
added: static field JoinGroupResponse.UNKNOWN_PROTOCOL: String
added: static field ListGroupsResponse.ERROR_CODE_KEY_NAME: String
added: static field ListGroupsResponse.GROUPS_KEY_NAME: String
added: static field ListGroupsResponse.GROUP_ID_KEY_NAME: String
added: static field ListGroupsResponse.PROTOCOL_TYPE_KEY_NAME: String
added: static field ListOffsetRequest.EARLIEST_TIMESTAMP: long
added: static field ListOffsetRequest.LATEST_TIMESTAMP: long
added: static field OffsetCommitRequest.DEFAULT_MEMBER_ID: String
added: static field OffsetCommitRequest.DEFAULT_RETENTION_TIME: long
added: static field OffsetFetchResponse.INVALID_OFFSET: long
added: static field OffsetFetchResponse.NO_METADATA: String
added: static field ProduceResponse.INVALID_OFFSET: long
added: static field SyncGroupRequest.GENERATION_ID_KEY_NAME: String
added: static field SyncGroupRequest.GROUP_ASSIGNMENT_KEY_NAME: String
added: static field SyncGroupRequest.GROUP_ID_KEY_NAME: String
added: static field SyncGroupRequest.MEMBER_ASSIGNMENT_KEY_NAME: String
added: static field SyncGroupRequest.MEMBER_ID_KEY_NAME: String
added: static field SyncGroupResponse.ERROR_CODE_KEY_NAME: String
added: static field SyncGroupResponse.MEMBER_ASSIGNMENT_KEY_NAME: String
added: static final class LeaderAndIsrRequest.EndPoint
added: static final class UpdateMetadataRequest.Broker
added: static final class UpdateMetadataRequest.BrokerEndPoint
added: static final class UpdateMetadataRequest.EndPoint
added: static final class UpdateMetadataRequest.PartitionState
added: static method AbstractRequest.getRequest(int, int, ByteBuffer): AbstractRequest
added: static method ControlledShutdownRequest.parse(ByteBuffer): ControlledShutdownRequest
added: static method ControlledShutdownRequest.parse(ByteBuffer, int): ControlledShutdownRequest
added: static method ControlledShutdownResponse.parse(ByteBuffer): ControlledShutdownResponse
added: static method ControlledShutdownResponse.parse(ByteBuffer, int): ControlledShutdownResponse
added: static method DescribeGroupsRequest.parse(ByteBuffer): DescribeGroupsRequest
added: static method DescribeGroupsRequest.parse(ByteBuffer, int): DescribeGroupsRequest
added: static method DescribeGroupsResponse.GroupMetadata.forError(Errors): DescribeGroupsResponse.GroupMetadata
added: static method DescribeGroupsResponse.fromError(Errors, List): DescribeGroupsResponse
added: static method DescribeGroupsResponse.parse(ByteBuffer): DescribeGroupsResponse
added: static method FetchRequest.parse(ByteBuffer, int): FetchRequest
added: static method FetchResponse.parse(ByteBuffer, int): FetchResponse
added: static method GroupCoordinatorRequest.parse(ByteBuffer): GroupCoordinatorRequest
added: static method GroupCoordinatorRequest.parse(ByteBuffer, int): GroupCoordinatorRequest
added: static method GroupCoordinatorResponse.parse(ByteBuffer): GroupCoordinatorResponse
added: static method HeartbeatRequest.parse(ByteBuffer, int): HeartbeatRequest
added: static method JoinGroupRequest.parse(ByteBuffer, int): JoinGroupRequest
added: static method LeaderAndIsrRequest.parse(ByteBuffer): LeaderAndIsrRequest
added: static method LeaderAndIsrRequest.parse(ByteBuffer, int): LeaderAndIsrRequest
added: static method LeaderAndIsrResponse.parse(ByteBuffer): LeaderAndIsrResponse
added: static method LeaderAndIsrResponse.parse(ByteBuffer, int): LeaderAndIsrResponse
added: static method LeaveGroupRequest.parse(ByteBuffer): LeaveGroupRequest
added: static method LeaveGroupRequest.parse(ByteBuffer, int): LeaveGroupRequest
added: static method LeaveGroupResponse.parse(ByteBuffer): LeaveGroupResponse
added: static method ListGroupsRequest.parse(ByteBuffer): ListGroupsRequest
added: static method ListGroupsRequest.parse(ByteBuffer, int): ListGroupsRequest
added: static method ListGroupsResponse.fromError(Errors): ListGroupsResponse
added: static method ListGroupsResponse.parse(ByteBuffer): ListGroupsResponse
added: static method ListOffsetRequest.parse(ByteBuffer, int): ListOffsetRequest
added: static method MetadataRequest.parse(ByteBuffer, int): MetadataRequest
added: static method OffsetFetchRequest.parse(ByteBuffer, int): OffsetFetchRequest
added: static method ProduceRequest.parse(ByteBuffer, int): ProduceRequest
added: static method StopReplicaRequest.parse(ByteBuffer): StopReplicaRequest
added: static method StopReplicaRequest.parse(ByteBuffer, int): StopReplicaRequest
added: static method StopReplicaResponse.parse(ByteBuffer): StopReplicaResponse
added: static method StopReplicaResponse.parse(ByteBuffer, int): StopReplicaResponse
added: static method SyncGroupRequest.parse(ByteBuffer, int): SyncGroupRequest
added: static method SyncGroupResponse.parse(ByteBuffer): SyncGroupResponse
added: static method UpdateMetadataRequest.parse(ByteBuffer): UpdateMetadataRequest
added: static method UpdateMetadataRequest.parse(ByteBuffer, int): UpdateMetadataRequest
added: static method UpdateMetadataResponse.parse(ByteBuffer): UpdateMetadataResponse
added: static method UpdateMetadataResponse.parse(ByteBuffer, int): UpdateMetadataResponse

added: class JaasUtils
added: ctor JaasUtils()
added: static field JaasUtils.JAVA_LOGIN_CONFIG_PARAM: String
added: static field JaasUtils.LOGIN_CONTEXT_CLIENT: String
added: static field JaasUtils.LOGIN_CONTEXT_SERVER: String
added: static field JaasUtils.SERVICE_NAME: String
added: static field JaasUtils.ZK_LOGIN_CONTEXT_NAME_KEY: String
added: static field JaasUtils.ZK_SASL_CLIENT: String
added: static method JaasUtils.defaultRealm(): String
added: static method JaasUtils.isZkSecurityEnabled(): boolean
added: static method JaasUtils.jaasConfig(String, String): String

added: class DefaultPrincipalBuilder implements PrincipalBuilder
added: class KafkaPrincipal implements Principal
added: ctor DefaultPrincipalBuilder()
added: ctor KafkaPrincipal(String, String)
added: interface PrincipalBuilder extends Configurable
added: method DefaultPrincipalBuilder.buildPrincipal(TransportLayer, Authenticator): Principal
added: method DefaultPrincipalBuilder.close(): void
added: method DefaultPrincipalBuilder.configure(Map): void
added: method KafkaPrincipal.equals(Object): boolean
added: method KafkaPrincipal.getName(): String
added: method KafkaPrincipal.getPrincipalType(): String
added: method KafkaPrincipal.hashCode(): int
added: method KafkaPrincipal.toString(): String
added: method PrincipalBuilder.buildPrincipal(TransportLayer, Authenticator): Principal
added: method PrincipalBuilder.close(): void
added: method PrincipalBuilder.configure(Map): void
added: static field KafkaPrincipal.ANONYMOUS: KafkaPrincipal
added: static field KafkaPrincipal.SEPARATOR: String
added: static field KafkaPrincipal.USER_TYPE: String
added: static method KafkaPrincipal.fromString(String): KafkaPrincipal

added: class SaslClientAuthenticator implements Authenticator
added: class SaslServerAuthenticator implements Authenticator
added: class SaslServerCallbackHandler implements CallbackHandler
added: ctor SaslClientAuthenticator(String, Subject, String, String)
added: ctor SaslClientAuthenticator.ClientCallbackHandler()
added: ctor SaslServerAuthenticator(String, Subject, KerberosShortNamer, int)
added: ctor SaslServerCallbackHandler(Configuration, KerberosShortNamer)
added: enum SaslClientAuthenticator.SaslState
added: method SaslClientAuthenticator.ClientCallbackHandler.handle(Callback[]): void
added: method SaslClientAuthenticator.authenticate(): void
added: method SaslClientAuthenticator.close(): void
added: method SaslClientAuthenticator.complete(): boolean
added: method SaslClientAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
added: method SaslClientAuthenticator.principal(): Principal
added: method SaslServerAuthenticator.authenticate(): void
added: method SaslServerAuthenticator.close(): void
added: method SaslServerAuthenticator.complete(): boolean
added: method SaslServerAuthenticator.configure(TransportLayer, PrincipalBuilder, Map): void
added: method SaslServerAuthenticator.principal(): Principal
added: method SaslServerCallbackHandler.handle(Callback[]): void
added: static class SaslClientAuthenticator.ClientCallbackHandler implements CallbackHandler
added: static field SaslClientAuthenticator.SaslState.COMPLETE: SaslClientAuthenticator.SaslState
added: static field SaslClientAuthenticator.SaslState.FAILED: SaslClientAuthenticator.SaslState
added: static field SaslClientAuthenticator.SaslState.INITIAL: SaslClientAuthenticator.SaslState
added: static field SaslClientAuthenticator.SaslState.INTERMEDIATE: SaslClientAuthenticator.SaslState
added: static method SaslClientAuthenticator.SaslState.valueOf(String): SaslClientAuthenticator.SaslState
added: static method SaslClientAuthenticator.SaslState.values(): SaslClientAuthenticator.SaslState[]

added: class BadFormatString extends IOException
added: class KerberosName
added: class KerberosShortNamer
added: class Login
added: class LoginManager
added: class NoMatchingRule extends IOException
added: ctor KerberosName(String, String, String)
added: ctor KerberosShortNamer(List)
added: ctor Login(String, Map)
added: method KerberosName.hostName(): String
added: method KerberosName.realm(): String
added: method KerberosName.serviceName(): String
added: method KerberosName.toString(): String
added: method KerberosShortNamer.shortName(KerberosName): String
added: method Login.shutdown(): void
added: method Login.startThreadIfNeeded(): void
added: method Login.subject(): Subject
added: method LoginManager.release(): void
added: method LoginManager.serviceName(): String
added: method LoginManager.subject(): Subject
added: static method KerberosName.parse(String): KerberosName
added: static method KerberosShortNamer.fromUnparsedRules(String, List): KerberosShortNamer
added: static method LoginManager.acquireLoginManager(LoginType, Map): LoginManager
added: static method LoginManager.closeAll(): void

added: class SslFactory implements Configurable
added: ctor SslFactory(Mode)
added: ctor SslFactory(Mode, String)
added: method SslFactory.configure(Map): void
added: method SslFactory.createSslEngine(String, int): SSLEngine
added: method SslFactory.sslContext(): SSLContext

changed: interface Deserializer → interface Deserializer extends Closeable
changed: interface Serializer → interface Serializer extends Closeable
added: class IntegerDeserializer implements Deserializer
added: class IntegerSerializer implements Serializer
added: class LongDeserializer implements Deserializer
added: class LongSerializer implements Serializer
added: ctor IntegerDeserializer()
added: ctor IntegerSerializer()
added: ctor LongDeserializer()
added: ctor LongSerializer()
added: method IntegerDeserializer.close(): void
added: method IntegerDeserializer.configure(Map, boolean): void
added: method IntegerDeserializer.deserialize(String, byte[]): Integer
added: method IntegerSerializer.close(): void
added: method IntegerSerializer.configure(Map, boolean): void
added: method IntegerSerializer.serialize(String, Integer): byte[]
added: method LongDeserializer.close(): void
added: method LongDeserializer.configure(Map, boolean): void
added: method LongDeserializer.deserialize(String, byte[]): Long
added: method LongSerializer.close(): void
added: method LongSerializer.configure(Map, boolean): void
added: method LongSerializer.serialize(String, Long): byte[]

removed: class ClientUtils
removed: ctor ClientUtils()
removed: static method ClientUtils.parseAndValidateAddresses(List): List
added: abstract class Shell
added: class AppInfoParser
added: class CircularIterator implements Iterator
added: ctor AppInfoParser()
added: ctor AppInfoParser.AppInfo()
added: ctor CircularIterator(List)
added: ctor Shell(long)
added: ctor Shell.ExitCodeException(int, String)
added: ctor Shell.ShellCommandExecutor(String[], long)
added: interface AppInfoParser.AppInfoMBean
added: method AppInfoParser.AppInfo.getCommitId(): String
added: method AppInfoParser.AppInfo.getVersion(): String
added: method AppInfoParser.AppInfoMBean.getCommitId(): String
added: method AppInfoParser.AppInfoMBean.getVersion(): String
added: method CircularIterator.hasNext(): boolean
added: method CircularIterator.next(): Object
added: method CircularIterator.peek(): Object
added: method CircularIterator.remove(): void
added: method Shell.ExitCodeException.getExitCode(): int
added: method Shell.ShellCommandExecutor.execString(): String[]
added: method Shell.ShellCommandExecutor.execute(): void
added: method Shell.ShellCommandExecutor.output(): String
added: method Shell.ShellCommandExecutor.parseExecResult(BufferedReader): void
added: method Shell.ShellCommandExecutor.toString(): String
added: method Shell.execString(): String[]
added: method Shell.exitCode(): int
added: method Shell.parseExecResult(BufferedReader): void
added: method Shell.process(): Process
added: method Shell.run(): void
added: static class AppInfoParser.AppInfo implements AppInfoParser.AppInfoMBean
added: static class Shell.ExitCodeException extends IOException
added: static class Shell.ShellCommandExecutor extends Shell
added: static method AppInfoParser.getCommitId(): String
added: static method AppInfoParser.getVersion(): String
added: static method AppInfoParser.registerAppInfo(String, String): void
added: static method AppInfoParser.unregisterAppInfo(String, String): void
added: static method Shell.execCommand(String[]): String
added: static method Shell.execCommand(String[], long): String
added: static method Utils.croak(String): void
added: static method Utils.daemonThread(String, Runnable): Thread
added: static method Utils.delete(File): void
added: static method Utils.ensureCapacity(ByteBuffer, int): ByteBuffer
added: static method Utils.getContextOrKafkaClassLoader(): ClassLoader
added: static method Utils.getKafkaClassLoader(): ClassLoader
added: static method Utils.join(Collection, String): String
added: static method Utils.join(Object[], String): String
added: static method Utils.loadProps(String): Properties
added: static method Utils.min(long, long[]): long
added: static method Utils.mkList(Object[]): List
added: static method Utils.mkSet(Object[]): Set
added: static method Utils.mkString(Collection, String): CharSequence
added: static method Utils.newInstance(String, Class): Object
added: static method Utils.newThread(String, Runnable, Boolean): Thread
added: static method Utils.propsToStringMap(Properties): Map
added: static method Utils.readBytes(ByteBuffer): byte[]
added: static method Utils.readBytes(ByteBuffer, int, int): byte[]
added: static method Utils.readFileAsString(String): String
added: static method Utils.readFileAsString(String, Charset): String
added: static method Utils.safe(List): List
added: static method Utils.sleep(long): void
added: static method Utils.sorted(Collection): List
added: static method Utils.stackTrace(Throwable): String
added: static method Utils.toArrayLE(int): byte[]