kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject [23/23] kafka git commit: MINOR: improve license header check by providing head file instead of (prefix) header regex
Date Tue, 28 Feb 2017 20:39:43 GMT
MINOR: improve license header check by providing head file instead of (prefix) header regex

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Jason Gustafson <jason@confluent.io>, Ewen Cheslack-Postava <ewen@confluent.io>

Closes #2303 from mjsax/licenseHeader


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d0e436c4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d0e436c4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d0e436c4

Branch: refs/heads/trunk
Commit: d0e436c471ba4122ddcc0f7a1624546f97c4a517
Parents: f3fab2e
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Tue Feb 28 12:35:04 2017 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Tue Feb 28 12:35:04 2017 -0800

----------------------------------------------------------------------
 checkstyle/checkstyle.xml                       |  4 +--
 checkstyle/java.header                          | 16 ++++++++++
 .../org/apache/kafka/clients/ClientRequest.java | 26 ++++++++-------
 .../apache/kafka/clients/ClientResponse.java    | 26 ++++++++-------
 .../org/apache/kafka/clients/ClientUtils.java   | 22 +++++++------
 .../kafka/clients/ClusterConnectionStates.java  | 26 ++++++++-------
 .../kafka/clients/CommonClientConfigs.java      | 23 ++++++++------
 .../apache/kafka/clients/ConnectionState.java   | 26 ++++++++-------
 .../apache/kafka/clients/InFlightRequests.java  | 26 ++++++++-------
 .../org/apache/kafka/clients/KafkaClient.java   | 26 ++++++++-------
 .../kafka/clients/ManualMetadataUpdater.java    | 23 ++++++++------
 .../java/org/apache/kafka/clients/Metadata.java | 22 +++++++------
 .../apache/kafka/clients/MetadataUpdater.java   | 23 ++++++++------
 .../org/apache/kafka/clients/NetworkClient.java | 22 +++++++------
 .../apache/kafka/clients/NodeApiVersions.java   | 22 +++++++------
 .../kafka/clients/RequestCompletionHandler.java | 26 ++++++++-------
 .../clients/consumer/CommitFailedException.java |  6 ++--
 .../apache/kafka/clients/consumer/Consumer.java | 22 +++++++------
 .../kafka/clients/consumer/ConsumerConfig.java  | 22 +++++++------
 .../clients/consumer/ConsumerInterceptor.java   | 22 +++++++------
 .../consumer/ConsumerRebalanceListener.java     | 22 +++++++------
 .../kafka/clients/consumer/ConsumerRecord.java  | 26 ++++++++-------
 .../kafka/clients/consumer/ConsumerRecords.java | 26 ++++++++-------
 .../consumer/InvalidOffsetException.java        | 22 +++++++------
 .../kafka/clients/consumer/KafkaConsumer.java   | 22 +++++++------
 .../kafka/clients/consumer/MockConsumer.java    | 22 +++++++------
 .../consumer/NoOffsetForPartitionException.java | 27 +++++++++-------
 .../clients/consumer/OffsetAndMetadata.java     | 22 +++++++------
 .../clients/consumer/OffsetAndTimestamp.java    |  6 ++--
 .../clients/consumer/OffsetCommitCallback.java  | 22 +++++++------
 .../consumer/OffsetOutOfRangeException.java     | 26 ++++++++-------
 .../clients/consumer/OffsetResetStrategy.java   | 22 +++++++------
 .../kafka/clients/consumer/RangeAssignor.java   | 12 +++----
 .../RetriableCommitFailedException.java         |  6 ++--
 .../clients/consumer/RoundRobinAssignor.java    | 26 ++++++++-------
 .../consumer/internals/AbstractCoordinator.java | 26 ++++++++-------
 .../internals/AbstractPartitionAssignor.java    | 26 ++++++++-------
 .../consumer/internals/ConsumerCoordinator.java | 22 +++++++------
 .../internals/ConsumerInterceptors.java         | 22 +++++++------
 .../internals/ConsumerNetworkClient.java        | 22 +++++++------
 .../consumer/internals/ConsumerProtocol.java    |  6 ++--
 .../clients/consumer/internals/Fetcher.java     | 23 ++++++++------
 .../clients/consumer/internals/Heartbeat.java   | 26 ++++++++-------
 .../internals/NoAvailableBrokersException.java  | 22 +++++++------
 .../NoOpConsumerRebalanceListener.java          | 27 +++++++++-------
 .../consumer/internals/PartitionAssignor.java   | 22 +++++++------
 .../consumer/internals/RequestFuture.java       | 22 +++++++------
 .../internals/RequestFutureAdapter.java         | 22 +++++++------
 .../internals/RequestFutureListener.java        | 22 +++++++------
 .../internals/StaleMetadataException.java       | 22 +++++++------
 .../consumer/internals/SubscriptionState.java   | 22 +++++++------
 .../producer/BufferExhaustedException.java      |  6 ++--
 .../apache/kafka/clients/producer/Callback.java |  6 ++--
 .../kafka/clients/producer/KafkaProducer.java   | 22 +++++++------
 .../kafka/clients/producer/MockProducer.java    |  6 ++--
 .../kafka/clients/producer/Partitioner.java     |  7 ++---
 .../apache/kafka/clients/producer/Producer.java |  6 ++--
 .../kafka/clients/producer/ProducerConfig.java  | 22 +++++++------
 .../clients/producer/ProducerInterceptor.java   |  6 ++--
 .../kafka/clients/producer/ProducerRecord.java  | 26 ++++++++-------
 .../kafka/clients/producer/RecordMetadata.java  |  6 ++--
 .../clients/producer/internals/BufferPool.java  |  6 ++--
 .../producer/internals/DefaultPartitioner.java  |  6 ++--
 .../internals/ErrorLoggingCallback.java         | 23 ++++++++------
 .../internals/FutureRecordMetadata.java         | 26 ++++++++-------
 .../internals/ProduceRequestResult.java         |  6 ++--
 .../internals/ProducerInterceptors.java         |  6 ++--
 .../producer/internals/RecordAccumulator.java   | 26 ++++++++-------
 .../clients/producer/internals/RecordBatch.java | 26 ++++++++-------
 .../clients/producer/internals/Sender.java      | 26 ++++++++-------
 .../java/org/apache/kafka/common/Cluster.java   | 26 ++++++++-------
 .../apache/kafka/common/ClusterResource.java    |  7 ++---
 .../kafka/common/ClusterResourceListener.java   | 23 ++++++++------
 .../org/apache/kafka/common/Configurable.java   |  6 ++--
 .../org/apache/kafka/common/KafkaException.java |  6 ++--
 .../java/org/apache/kafka/common/Metric.java    |  6 ++--
 .../org/apache/kafka/common/MetricName.java     | 24 ++++++++------
 .../main/java/org/apache/kafka/common/Node.java | 22 +++++++------
 .../org/apache/kafka/common/PartitionInfo.java  | 26 ++++++++-------
 .../org/apache/kafka/common/TopicPartition.java |  6 ++--
 .../common/annotation/InterfaceStability.java   | 22 +++++++------
 .../org/apache/kafka/common/cache/Cache.java    |  9 +++---
 .../org/apache/kafka/common/cache/LRUCache.java |  9 +++---
 .../kafka/common/cache/SynchronizedCache.java   |  9 +++---
 .../kafka/common/config/AbstractConfig.java     | 22 +++++++------
 .../org/apache/kafka/common/config/Config.java  | 22 +++++++------
 .../apache/kafka/common/config/ConfigDef.java   | 22 +++++++------
 .../kafka/common/config/ConfigException.java    |  6 ++--
 .../apache/kafka/common/config/ConfigValue.java | 15 +++++----
 .../apache/kafka/common/config/SaslConfigs.java | 23 ++++++++------
 .../apache/kafka/common/config/SslConfigs.java  | 23 ++++++++------
 .../kafka/common/config/types/Password.java     |  9 +++---
 .../kafka/common/errors/ApiException.java       |  6 ++--
 .../common/errors/AuthenticationException.java  | 22 +++++++------
 .../common/errors/AuthorizationException.java   | 22 +++++++------
 .../errors/BrokerNotAvailableException.java     |  7 ++---
 .../errors/ClusterAuthorizationException.java   | 22 +++++++------
 .../common/errors/ControllerMovedException.java |  7 ++---
 .../common/errors/CorruptRecordException.java   | 22 +++++++------
 .../common/errors/DisconnectException.java      | 22 +++++++------
 .../errors/GroupAuthorizationException.java     | 22 +++++++------
 .../GroupCoordinatorNotAvailableException.java  | 23 ++++++++------
 .../errors/GroupLoadInProgressException.java    | 23 ++++++++------
 .../errors/IllegalGenerationException.java      | 22 +++++++------
 .../errors/IllegalSaslStateException.java       | 22 +++++++------
 .../InconsistentGroupProtocolException.java     | 22 +++++++------
 .../kafka/common/errors/InterruptException.java | 26 ++++++++-------
 .../InvalidCommitOffsetSizeException.java       | 22 +++++++------
 .../errors/InvalidConfigurationException.java   |  8 ++---
 .../errors/InvalidFetchSizeException.java       | 22 +++++++------
 .../common/errors/InvalidGroupIdException.java  | 22 +++++++------
 .../common/errors/InvalidMetadataException.java | 27 +++++++++-------
 .../common/errors/InvalidOffsetException.java   |  7 ++---
 .../errors/InvalidPartitionsException.java      |  8 ++---
 .../InvalidReplicaAssignmentException.java      |  8 ++---
 .../InvalidReplicationFactorException.java      |  8 ++---
 .../common/errors/InvalidRequestException.java  |  8 ++---
 .../errors/InvalidRequiredAcksException.java    |  8 ++---
 .../errors/InvalidSessionTimeoutException.java  | 22 +++++++------
 .../errors/InvalidTimestampException.java       |  7 ++---
 .../common/errors/InvalidTopicException.java    | 26 ++++++++-------
 .../errors/LeaderNotAvailableException.java     | 22 +++++++------
 .../kafka/common/errors/NetworkException.java   | 26 ++++++++-------
 .../common/errors/NotControllerException.java   | 23 ++++++++------
 .../errors/NotCoordinatorForGroupException.java | 23 ++++++++------
 .../NotEnoughReplicasAfterAppendException.java  |  8 ++---
 .../errors/NotEnoughReplicasException.java      |  8 ++---
 .../errors/NotLeaderForPartitionException.java  | 26 ++++++++-------
 .../common/errors/OffsetMetadataTooLarge.java   | 22 +++++++------
 .../errors/OffsetOutOfRangeException.java       |  7 ++---
 .../common/errors/PolicyViolationException.java |  7 ++---
 .../errors/RebalanceInProgressException.java    |  6 ++--
 .../errors/RecordBatchTooLargeException.java    | 22 +++++++------
 .../common/errors/RecordTooLargeException.java  | 26 ++++++++-------
 .../errors/ReplicaNotAvailableException.java    |  7 ++---
 .../kafka/common/errors/RetriableException.java | 26 ++++++++-------
 .../common/errors/SerializationException.java   | 22 +++++++------
 .../kafka/common/errors/TimeoutException.java   | 26 ++++++++-------
 .../errors/TopicAuthorizationException.java     | 22 +++++++------
 .../common/errors/TopicExistsException.java     |  8 ++---
 .../common/errors/UnknownMemberIdException.java | 22 +++++++------
 .../common/errors/UnknownServerException.java   | 26 ++++++++-------
 .../UnknownTopicOrPartitionException.java       | 26 ++++++++-------
 .../UnsupportedForMessageFormatException.java   | 22 +++++++------
 .../UnsupportedSaslMechanismException.java      | 22 +++++++------
 .../errors/UnsupportedVersionException.java     | 22 +++++++------
 .../kafka/common/errors/WakeupException.java    | 22 +++++++------
 .../internals/ClusterResourceListeners.java     |  7 ++---
 .../kafka/common/internals/FatalExitError.java  | 22 +++++++------
 .../kafka/common/internals/PartitionStates.java |  7 ++---
 .../kafka/common/metrics/CompoundStat.java      |  6 ++--
 .../kafka/common/metrics/JmxReporter.java       | 26 ++++++++-------
 .../kafka/common/metrics/KafkaMetric.java       |  6 ++--
 .../apache/kafka/common/metrics/Measurable.java | 26 ++++++++-------
 .../kafka/common/metrics/MeasurableStat.java    |  6 ++--
 .../kafka/common/metrics/MetricConfig.java      |  6 ++--
 .../apache/kafka/common/metrics/Metrics.java    | 26 ++++++++-------
 .../kafka/common/metrics/MetricsReporter.java   | 26 ++++++++-------
 .../org/apache/kafka/common/metrics/Quota.java  |  6 ++--
 .../common/metrics/QuotaViolationException.java |  6 ++--
 .../org/apache/kafka/common/metrics/Sensor.java | 26 ++++++++-------
 .../org/apache/kafka/common/metrics/Stat.java   |  6 ++--
 .../apache/kafka/common/metrics/stats/Avg.java  | 26 ++++++++-------
 .../kafka/common/metrics/stats/Count.java       | 26 ++++++++-------
 .../kafka/common/metrics/stats/Histogram.java   |  6 ++--
 .../apache/kafka/common/metrics/stats/Max.java  | 26 ++++++++-------
 .../apache/kafka/common/metrics/stats/Min.java  | 26 ++++++++-------
 .../kafka/common/metrics/stats/Percentile.java  |  6 ++--
 .../kafka/common/metrics/stats/Percentiles.java | 26 ++++++++-------
 .../apache/kafka/common/metrics/stats/Rate.java | 26 ++++++++-------
 .../kafka/common/metrics/stats/SampledStat.java | 26 ++++++++-------
 .../kafka/common/metrics/stats/SimpleRate.java  | 12 +++----
 .../kafka/common/metrics/stats/Total.java       | 26 ++++++++-------
 .../kafka/common/metrics/stats/Value.java       | 22 +++++++------
 .../kafka/common/network/Authenticator.java     |  7 ++---
 .../kafka/common/network/ByteBufferReceive.java |  6 ++--
 .../kafka/common/network/ByteBufferSend.java    | 22 +++++++------
 .../kafka/common/network/ChannelBuilder.java    | 22 +++++++------
 .../kafka/common/network/ChannelBuilders.java   | 23 ++++++++------
 .../common/network/DefaultAuthenticator.java    |  7 ++---
 .../common/network/InvalidReceiveException.java |  8 ++---
 .../kafka/common/network/KafkaChannel.java      |  7 ++---
 .../kafka/common/network/ListenerName.java      |  8 ++---
 .../org/apache/kafka/common/network/Mode.java   |  6 ++--
 .../apache/kafka/common/network/MultiSend.java  |  8 ++---
 .../kafka/common/network/NetworkReceive.java    | 22 +++++++------
 .../kafka/common/network/NetworkSend.java       |  6 ++--
 .../common/network/PlaintextChannelBuilder.java | 22 +++++++------
 .../common/network/PlaintextTransportLayer.java |  7 ++---
 .../apache/kafka/common/network/Receive.java    |  6 ++--
 .../common/network/SaslChannelBuilder.java      | 22 +++++++------
 .../apache/kafka/common/network/Selectable.java | 22 +++++++------
 .../apache/kafka/common/network/Selector.java   | 22 +++++++------
 .../org/apache/kafka/common/network/Send.java   | 22 +++++++------
 .../kafka/common/network/SslChannelBuilder.java | 22 +++++++------
 .../kafka/common/network/SslTransportLayer.java |  7 ++---
 .../kafka/common/network/TransportLayer.java    |  7 ++---
 .../kafka/common/network/TransportLayers.java   |  7 ++---
 .../apache/kafka/common/protocol/ApiKeys.java   |  6 ++--
 .../apache/kafka/common/protocol/Errors.java    |  6 ++--
 .../apache/kafka/common/protocol/Protocol.java  |  6 ++--
 .../kafka/common/protocol/SecurityProtocol.java |  8 ++---
 .../kafka/common/protocol/types/ArrayOf.java    |  6 ++--
 .../kafka/common/protocol/types/Field.java      |  6 ++--
 .../kafka/common/protocol/types/Schema.java     | 26 ++++++++-------
 .../common/protocol/types/SchemaException.java  |  6 ++--
 .../kafka/common/protocol/types/Struct.java     | 22 +++++++------
 .../kafka/common/protocol/types/Type.java       |  6 ++--
 .../kafka/common/record/AbstractRecords.java    | 14 ++++-----
 .../common/record/ByteBufferInputStream.java    |  6 ++--
 .../common/record/ByteBufferLogInputStream.java | 14 ++++-----
 .../common/record/ByteBufferOutputStream.java   |  6 ++--
 .../kafka/common/record/CompressionType.java    |  6 ++--
 .../kafka/common/record/FileLogInputStream.java | 14 ++++-----
 .../apache/kafka/common/record/FileRecords.java | 14 ++++-----
 .../common/record/InvalidRecordException.java   |  6 ++--
 .../common/record/KafkaLZ4BlockInputStream.java |  7 ++---
 .../record/KafkaLZ4BlockOutputStream.java       |  7 ++---
 .../apache/kafka/common/record/LogEntry.java    |  6 ++--
 .../kafka/common/record/LogInputStream.java     | 14 ++++-----
 .../kafka/common/record/MemoryRecords.java      | 26 ++++++++-------
 .../common/record/MemoryRecordsBuilder.java     |  6 ++--
 .../org/apache/kafka/common/record/Record.java  |  6 ++--
 .../org/apache/kafka/common/record/Records.java |  6 ++--
 .../kafka/common/record/RecordsIterator.java    | 14 ++++-----
 .../kafka/common/record/TimestampType.java      |  7 ++---
 .../kafka/common/requests/AbstractRequest.java  |  8 ++---
 .../requests/AbstractRequestResponse.java       | 22 +++++++------
 .../kafka/common/requests/AbstractResponse.java | 14 ++++-----
 .../common/requests/ApiVersionsRequest.java     | 22 +++++++------
 .../common/requests/ApiVersionsResponse.java    | 22 +++++++------
 .../requests/ControlledShutdownRequest.java     | 22 +++++++------
 .../requests/ControlledShutdownResponse.java    | 22 +++++++------
 .../common/requests/CreateTopicsRequest.java    |  8 ++---
 .../common/requests/CreateTopicsResponse.java   |  8 ++---
 .../common/requests/DeleteTopicsRequest.java    |  8 ++---
 .../common/requests/DeleteTopicsResponse.java   |  8 ++---
 .../common/requests/DescribeGroupsRequest.java  | 22 +++++++------
 .../common/requests/DescribeGroupsResponse.java | 22 +++++++------
 .../kafka/common/requests/FetchRequest.java     | 22 +++++++------
 .../kafka/common/requests/FetchResponse.java    |  6 ++--
 .../requests/GroupCoordinatorRequest.java       | 22 +++++++------
 .../requests/GroupCoordinatorResponse.java      | 22 +++++++------
 .../kafka/common/requests/HeartbeatRequest.java | 22 +++++++------
 .../common/requests/HeartbeatResponse.java      | 22 +++++++------
 .../kafka/common/requests/JoinGroupRequest.java | 22 +++++++------
 .../common/requests/JoinGroupResponse.java      | 22 +++++++------
 .../common/requests/LeaderAndIsrRequest.java    |  7 ++---
 .../common/requests/LeaderAndIsrResponse.java   | 23 ++++++++------
 .../common/requests/LeaveGroupRequest.java      | 22 +++++++------
 .../common/requests/LeaveGroupResponse.java     | 22 +++++++------
 .../common/requests/ListGroupsRequest.java      | 22 +++++++------
 .../common/requests/ListGroupsResponse.java     | 22 +++++++------
 .../common/requests/ListOffsetRequest.java      |  6 ++--
 .../common/requests/ListOffsetResponse.java     |  6 ++--
 .../kafka/common/requests/MetadataRequest.java  | 22 +++++++------
 .../kafka/common/requests/MetadataResponse.java | 22 +++++++------
 .../common/requests/OffsetCommitRequest.java    | 22 +++++++------
 .../common/requests/OffsetCommitResponse.java   | 22 +++++++------
 .../common/requests/OffsetFetchRequest.java     | 22 +++++++------
 .../common/requests/OffsetFetchResponse.java    | 22 +++++++------
 .../kafka/common/requests/PartitionState.java   | 23 ++++++++------
 .../kafka/common/requests/ProduceRequest.java   | 23 ++++++++------
 .../kafka/common/requests/ProduceResponse.java  | 26 ++++++++-------
 .../kafka/common/requests/RecordsSend.java      | 14 ++++-----
 .../kafka/common/requests/RequestAndSize.java   |  6 ++--
 .../kafka/common/requests/RequestHeader.java    | 26 ++++++++-------
 .../kafka/common/requests/ResponseHeader.java   |  6 ++--
 .../common/requests/SaslHandshakeRequest.java   | 18 +++++------
 .../common/requests/SaslHandshakeResponse.java  | 18 +++++------
 .../common/requests/StopReplicaRequest.java     | 23 ++++++++------
 .../common/requests/StopReplicaResponse.java    | 23 ++++++++------
 .../kafka/common/requests/SyncGroupRequest.java |  6 ++--
 .../common/requests/SyncGroupResponse.java      |  6 ++--
 .../common/requests/UpdateMetadataRequest.java  | 23 ++++++++------
 .../common/requests/UpdateMetadataResponse.java | 23 ++++++++------
 .../kafka/common/security/JaasConfig.java       |  7 ++---
 .../kafka/common/security/JaasContext.java      |  9 +++---
 .../apache/kafka/common/security/JaasUtils.java |  8 ++---
 .../security/auth/AuthCallbackHandler.java      |  7 ++---
 .../security/auth/DefaultPrincipalBuilder.java  |  7 ++---
 .../common/security/auth/KafkaPrincipal.java    | 12 +++----
 .../kafka/common/security/auth/Login.java       | 18 +++++------
 .../common/security/auth/PrincipalBuilder.java  |  7 ++---
 .../security/authenticator/AbstractLogin.java   | 18 +++++------
 .../security/authenticator/CredentialCache.java | 18 +++++------
 .../security/authenticator/DefaultLogin.java    | 18 +++++------
 .../security/authenticator/LoginManager.java    | 18 +++++------
 .../authenticator/SaslClientAuthenticator.java  | 18 +++++------
 .../SaslClientCallbackHandler.java              | 17 +++++-----
 .../authenticator/SaslServerAuthenticator.java  |  7 ++---
 .../SaslServerCallbackHandler.java              | 18 +++++------
 .../security/kerberos/BadFormatString.java      | 18 +++++------
 .../common/security/kerberos/KerberosLogin.java | 18 +++++------
 .../common/security/kerberos/KerberosName.java  | 18 +++++------
 .../common/security/kerberos/KerberosRule.java  | 18 +++++------
 .../security/kerberos/KerberosShortNamer.java   | 18 +++++------
 .../security/kerberos/NoMatchingRule.java       | 18 +++++------
 .../common/security/plain/PlainLoginModule.java | 18 +++++------
 .../common/security/plain/PlainSaslServer.java  | 18 +++++------
 .../security/plain/PlainSaslServerProvider.java | 18 +++++------
 .../common/security/scram/ScramCredential.java  | 18 +++++------
 .../security/scram/ScramCredentialCallback.java |  7 ++---
 .../security/scram/ScramCredentialUtils.java    | 20 ++++++------
 .../common/security/scram/ScramFormatter.java   | 18 +++++------
 .../common/security/scram/ScramLoginModule.java | 18 +++++------
 .../common/security/scram/ScramMechanism.java   | 18 +++++------
 .../common/security/scram/ScramMessages.java    | 18 +++++------
 .../common/security/scram/ScramSaslClient.java  | 18 +++++------
 .../security/scram/ScramSaslClientProvider.java | 18 +++++------
 .../common/security/scram/ScramSaslServer.java  | 18 +++++------
 .../security/scram/ScramSaslServerProvider.java | 18 +++++------
 .../scram/ScramServerCallbackHandler.java       |  7 ++---
 .../kafka/common/security/ssl/SslFactory.java   |  6 ++--
 .../serialization/ByteArrayDeserializer.java    | 23 ++++++++------
 .../serialization/ByteArraySerializer.java      | 23 ++++++++------
 .../serialization/ByteBufferDeserializer.java   | 22 +++++++------
 .../serialization/ByteBufferSerializer.java     | 22 +++++++------
 .../common/serialization/BytesDeserializer.java | 22 +++++++------
 .../common/serialization/BytesSerializer.java   | 22 +++++++------
 .../common/serialization/Deserializer.java      | 23 ++++++++------
 .../serialization/DoubleDeserializer.java       | 22 +++++++------
 .../common/serialization/DoubleSerializer.java  | 22 +++++++------
 .../serialization/IntegerDeserializer.java      | 22 +++++++------
 .../common/serialization/IntegerSerializer.java | 22 +++++++------
 .../common/serialization/LongDeserializer.java  | 22 +++++++------
 .../common/serialization/LongSerializer.java    | 22 +++++++------
 .../kafka/common/serialization/Serde.java       | 23 ++++++++------
 .../kafka/common/serialization/Serdes.java      | 23 ++++++++------
 .../kafka/common/serialization/Serializer.java  | 23 ++++++++------
 .../serialization/StringDeserializer.java       | 22 +++++++------
 .../common/serialization/StringSerializer.java  | 22 +++++++------
 .../kafka/common/utils/AbstractIterator.java    |  6 ++--
 .../kafka/common/utils/AppInfoParser.java       |  6 ++--
 .../org/apache/kafka/common/utils/Bytes.java    |  7 ++---
 .../kafka/common/utils/CircularIterator.java    |  9 +++---
 .../kafka/common/utils/CollectionUtils.java     | 22 +++++++------
 .../kafka/common/utils/CopyOnWriteMap.java      | 26 ++++++++-------
 .../org/apache/kafka/common/utils/Crc32.java    | 26 ++++++++-------
 .../org/apache/kafka/common/utils/Exit.java     |  7 ++---
 .../apache/kafka/common/utils/KafkaThread.java  | 26 ++++++++-------
 .../org/apache/kafka/common/utils/Shell.java    | 19 +++++------
 .../apache/kafka/common/utils/SystemTime.java   |  6 ++--
 .../org/apache/kafka/common/utils/Time.java     |  6 ++--
 .../org/apache/kafka/common/utils/Utils.java    | 22 +++++++------
 .../kafka/server/policy/CreateTopicPolicy.java  | 23 ++++++++------
 .../apache/kafka/clients/ClientUtilsTest.java   |  6 ++--
 .../org/apache/kafka/clients/MetadataTest.java  | 22 +++++++------
 .../org/apache/kafka/clients/MockClient.java    |  6 ++--
 .../apache/kafka/clients/NetworkClientTest.java |  6 ++--
 .../kafka/clients/NodeApiVersionsTest.java      |  6 ++--
 .../clients/consumer/ConsumerConfigTest.java    | 12 +++----
 .../clients/consumer/ConsumerRecordTest.java    | 14 ++++-----
 .../clients/consumer/ConsumerRecordsTest.java   | 11 +++----
 .../clients/consumer/KafkaConsumerTest.java     |  6 ++--
 .../clients/consumer/MockConsumerTest.java      |  6 ++--
 .../clients/consumer/RangeAssignorTest.java     | 12 +++----
 .../consumer/RoundRobinAssignorTest.java        | 26 ++++++++-------
 ...alizeCompatibilityOffsetAndMetadataTest.java | 23 ++++++++------
 .../internals/AbstractCoordinatorTest.java      | 14 ++++-----
 .../internals/ConsumerCoordinatorTest.java      |  6 ++--
 .../internals/ConsumerInterceptorsTest.java     |  6 ++--
 .../internals/ConsumerNetworkClientTest.java    | 22 +++++++------
 .../internals/ConsumerProtocolTest.java         | 12 +++----
 .../clients/consumer/internals/FetcherTest.java |  6 ++--
 .../consumer/internals/HeartbeatTest.java       |  6 ++--
 .../internals/MockPartitionAssignor.java        | 12 +++----
 .../consumer/internals/RequestFutureTest.java   | 22 +++++++------
 .../internals/SubscriptionStateTest.java        |  6 ++--
 .../clients/producer/KafkaProducerTest.java     |  8 ++---
 .../clients/producer/MockProducerTest.java      |  6 ++--
 .../clients/producer/ProducerRecordTest.java    |  6 ++--
 .../kafka/clients/producer/RecordSendTest.java  |  6 ++--
 .../producer/internals/BufferPoolTest.java      |  6 ++--
 .../internals/DefaultPartitionerTest.java       | 22 +++++++------
 .../internals/ProducerInterceptorsTest.java     | 22 +++++++------
 .../internals/RecordAccumulatorTest.java        | 26 ++++++++-------
 .../clients/producer/internals/SenderTest.java  | 22 +++++++------
 .../org/apache/kafka/common/ClusterTest.java    | 22 +++++++------
 .../apache/kafka/common/PartitionInfoTest.java  | 22 +++++++------
 ...erializeCompatibilityTopicPartitionTest.java | 23 ++++++++------
 .../apache/kafka/common/cache/LRUCacheTest.java |  9 +++---
 .../kafka/common/config/AbstractConfigTest.java | 26 ++++++++-------
 .../kafka/common/config/ConfigDefTest.java      | 22 +++++++------
 .../common/internals/PartitionStatesTest.java   |  7 ++---
 .../common/metrics/FakeMetricsReporter.java     | 26 ++++++++-------
 .../kafka/common/metrics/JmxReporterTest.java   |  6 ++--
 .../kafka/common/metrics/MetricsTest.java       | 26 ++++++++-------
 .../apache/kafka/common/metrics/SensorTest.java | 22 +++++++------
 .../common/metrics/stats/HistogramTest.java     |  6 ++--
 .../apache/kafka/common/network/CertStores.java | 22 +++++++------
 .../apache/kafka/common/network/EchoServer.java | 22 +++++++------
 .../kafka/common/network/NetworkTestUtils.java  | 22 +++++++------
 .../kafka/common/network/NioEchoServer.java     | 22 +++++++------
 .../kafka/common/network/SelectorTest.java      | 22 +++++++------
 .../kafka/common/network/SslSelectorTest.java   | 22 +++++++------
 .../common/network/SslTransportLayerTest.java   | 22 +++++++------
 .../kafka/common/protocol/ApiKeysTest.java      |  7 ++---
 .../kafka/common/protocol/ErrorsTest.java       |  6 ++--
 .../types/ProtocolSerializationTest.java        |  6 ++--
 .../record/ByteBufferLogInputStreamTest.java    | 14 ++++-----
 .../common/record/CompressionTypeTest.java      | 14 ++++-----
 .../kafka/common/record/FileRecordsTest.java    | 14 ++++-----
 .../kafka/common/record/KafkaLZ4Test.java       |  6 ++--
 .../common/record/MemoryRecordsBuilderTest.java | 14 ++++-----
 .../kafka/common/record/MemoryRecordsTest.java  |  6 ++--
 .../apache/kafka/common/record/RecordTest.java  |  6 ++--
 .../kafka/common/record/SimpleRecordTest.java   |  6 ++--
 .../kafka/common/record/TimestampTypeTest.java  | 14 ++++-----
 .../common/requests/RequestResponseTest.java    | 23 ++++++++------
 .../kafka/common/security/JaasContextTest.java  | 12 +++----
 .../common/security/TestSecurityConfig.java     | 22 +++++++------
 .../security/auth/KafkaPrincipalTest.java       | 12 +++----
 .../authenticator/SaslAuthenticatorTest.java    | 22 +++++++------
 .../authenticator/TestDigestLoginModule.java    | 22 +++++++------
 .../security/authenticator/TestJaasConfig.java  | 22 +++++++------
 .../security/kerberos/KerberosNameTest.java     |  7 ++---
 .../scram/ScramCredentialUtilsTest.java         |  7 ++---
 .../security/scram/ScramFormatterTest.java      |  7 ++---
 .../security/scram/ScramMessagesTest.java       |  7 ++---
 .../common/security/ssl/SslFactoryTest.java     | 22 +++++++------
 .../common/serialization/SerializationTest.java | 22 +++++++------
 .../common/utils/AbstractIteratorTest.java      |  6 ++--
 .../org/apache/kafka/common/utils/CrcTest.java  |  6 ++--
 .../org/apache/kafka/common/utils/MockTime.java | 22 +++++++------
 .../apache/kafka/common/utils/Serializer.java   | 23 ++++++++------
 .../apache/kafka/common/utils/UtilsTest.java    |  6 ++--
 .../org/apache/kafka/test/DelayedReceive.java   |  6 ++--
 .../org/apache/kafka/test/MetricsBench.java     | 26 ++++++++-------
 .../org/apache/kafka/test/Microbenchmarks.java  | 26 ++++++++-------
 .../kafka/test/MockClusterResourceListener.java |  7 ++---
 .../kafka/test/MockConsumerInterceptor.java     |  6 ++--
 .../org/apache/kafka/test/MockDeserializer.java |  6 ++--
 .../apache/kafka/test/MockMetricsReporter.java  |  6 ++--
 .../org/apache/kafka/test/MockPartitioner.java  |  6 ++--
 .../kafka/test/MockProducerInterceptor.java     |  6 ++--
 .../org/apache/kafka/test/MockSelector.java     | 22 +++++++------
 .../org/apache/kafka/test/MockSerializer.java   |  6 ++--
 .../org/apache/kafka/test/TestCondition.java    | 30 +++++++++---------
 .../org/apache/kafka/test/TestSslUtils.java     |  7 ++---
 .../java/org/apache/kafka/test/TestUtils.java   | 12 +++----
 .../kafka/connect/connector/ConnectRecord.java  | 15 +++++----
 .../kafka/connect/connector/Connector.java      |  9 +++---
 .../connect/connector/ConnectorContext.java     |  9 +++---
 .../apache/kafka/connect/connector/Task.java    |  9 +++---
 .../kafka/connect/data/ConnectSchema.java       |  9 +++---
 .../org/apache/kafka/connect/data/Date.java     |  9 +++---
 .../org/apache/kafka/connect/data/Decimal.java  |  9 +++---
 .../org/apache/kafka/connect/data/Field.java    |  9 +++---
 .../org/apache/kafka/connect/data/Schema.java   |  9 +++---
 .../kafka/connect/data/SchemaAndValue.java      |  9 +++---
 .../kafka/connect/data/SchemaBuilder.java       |  9 +++---
 .../kafka/connect/data/SchemaProjector.java     | 27 ++++++++--------
 .../org/apache/kafka/connect/data/Struct.java   |  9 +++---
 .../org/apache/kafka/connect/data/Time.java     |  9 +++---
 .../apache/kafka/connect/data/Timestamp.java    |  9 +++---
 .../connect/errors/AlreadyExistsException.java  |  9 +++---
 .../kafka/connect/errors/ConnectException.java  |  9 +++---
 .../kafka/connect/errors/DataException.java     |  9 +++---
 .../errors/IllegalWorkerStateException.java     |  9 +++---
 .../kafka/connect/errors/NotFoundException.java |  9 +++---
 .../connect/errors/RetriableException.java      |  9 +++---
 .../connect/errors/SchemaBuilderException.java  |  9 +++---
 .../errors/SchemaProjectorException.java        | 26 ++++++++-------
 .../kafka/connect/sink/SinkConnector.java       |  9 +++---
 .../apache/kafka/connect/sink/SinkRecord.java   | 15 +++++----
 .../org/apache/kafka/connect/sink/SinkTask.java |  8 ++---
 .../kafka/connect/sink/SinkTaskContext.java     |  9 +++---
 .../kafka/connect/source/SourceConnector.java   |  8 ++---
 .../kafka/connect/source/SourceRecord.java      | 15 +++++----
 .../apache/kafka/connect/source/SourceTask.java |  9 +++---
 .../kafka/connect/source/SourceTaskContext.java |  8 ++---
 .../apache/kafka/connect/storage/Converter.java |  9 +++---
 .../connect/storage/OffsetStorageReader.java    |  9 +++---
 .../kafka/connect/storage/StringConverter.java  |  9 +++---
 .../connect/transforms/Transformation.java      |  9 +++---
 .../kafka/connect/util/ConnectorUtils.java      |  9 +++---
 .../connector/ConnectorReconfigurationTest.java |  9 +++---
 .../kafka/connect/data/ConnectSchemaTest.java   |  9 +++---
 .../org/apache/kafka/connect/data/DateTest.java |  9 +++---
 .../apache/kafka/connect/data/DecimalTest.java  |  9 +++---
 .../apache/kafka/connect/data/FakeSchema.java   |  9 +++---
 .../apache/kafka/connect/data/FieldTest.java    |  9 +++---
 .../kafka/connect/data/SchemaBuilderTest.java   |  9 +++---
 .../kafka/connect/data/SchemaProjectorTest.java | 27 ++++++++--------
 .../apache/kafka/connect/data/StructTest.java   |  9 +++---
 .../org/apache/kafka/connect/data/TimeTest.java |  9 +++---
 .../kafka/connect/data/TimestampTest.java       |  9 +++---
 .../connect/storage/StringConverterTest.java    |  9 +++---
 .../kafka/connect/util/ConnectorUtilsTest.java  |  9 +++---
 .../connect/file/FileStreamSinkConnector.java   |  9 +++---
 .../kafka/connect/file/FileStreamSinkTask.java  |  9 +++---
 .../connect/file/FileStreamSourceConnector.java |  9 +++---
 .../connect/file/FileStreamSourceTask.java      |  9 +++---
 .../file/FileStreamSinkConnectorTest.java       |  9 +++---
 .../connect/file/FileStreamSinkTaskTest.java    |  9 +++---
 .../file/FileStreamSourceConnectorTest.java     |  9 +++---
 .../connect/file/FileStreamSourceTaskTest.java  |  9 +++---
 .../kafka/connect/json/JsonConverter.java       | 15 +++++----
 .../kafka/connect/json/JsonDeserializer.java    | 14 ++++-----
 .../apache/kafka/connect/json/JsonSchema.java   |  9 +++---
 .../kafka/connect/json/JsonSerializer.java      | 14 ++++-----
 .../kafka/connect/json/JsonConverterTest.java   |  9 +++---
 .../kafka/connect/cli/ConnectDistributed.java   |  9 +++---
 .../kafka/connect/cli/ConnectStandalone.java    | 15 +++++----
 .../kafka/connect/runtime/AbstractHerder.java   | 14 ++++-----
 .../kafka/connect/runtime/AbstractStatus.java   | 14 ++++-----
 .../apache/kafka/connect/runtime/Connect.java   | 15 +++++----
 .../kafka/connect/runtime/ConnectorConfig.java  | 15 +++++----
 .../kafka/connect/runtime/ConnectorFactory.java | 29 ++++++++---------
 .../kafka/connect/runtime/ConnectorStatus.java  |  8 ++---
 .../apache/kafka/connect/runtime/Herder.java    | 15 +++++----
 .../connect/runtime/HerderConnectorContext.java | 15 +++++----
 .../kafka/connect/runtime/PluginDiscovery.java  | 15 +++++----
 .../connect/runtime/SinkConnectorConfig.java    | 15 +++++----
 .../connect/runtime/SourceConnectorConfig.java  | 15 +++++----
 .../runtime/SourceTaskOffsetCommitter.java      | 15 +++++----
 .../kafka/connect/runtime/TargetState.java      | 14 ++++-----
 .../kafka/connect/runtime/TaskConfig.java       |  9 +++---
 .../kafka/connect/runtime/TaskStatus.java       | 14 ++++-----
 .../connect/runtime/TransformationChain.java    | 15 +++++----
 .../apache/kafka/connect/runtime/Worker.java    | 15 +++++----
 .../kafka/connect/runtime/WorkerConfig.java     | 15 +++++----
 .../kafka/connect/runtime/WorkerConnector.java  | 14 ++++-----
 .../kafka/connect/runtime/WorkerSinkTask.java   | 15 +++++----
 .../connect/runtime/WorkerSinkTaskContext.java  | 27 +++++++++-------
 .../kafka/connect/runtime/WorkerSourceTask.java | 15 +++++----
 .../runtime/WorkerSourceTaskContext.java        |  9 +++---
 .../kafka/connect/runtime/WorkerTask.java       | 15 +++++----
 .../runtime/distributed/ClusterConfigState.java |  9 +++---
 .../runtime/distributed/ConnectProtocol.java    |  9 +++---
 .../runtime/distributed/DistributedConfig.java  |  9 +++---
 .../runtime/distributed/DistributedHerder.java  |  9 +++---
 .../distributed/NotAssignedException.java       | 14 ++++-----
 .../runtime/distributed/NotLeaderException.java |  9 +++---
 .../distributed/RebalanceNeededException.java   | 14 ++++-----
 .../distributed/RequestTargetException.java     | 14 ++++-----
 .../runtime/distributed/WorkerCoordinator.java  |  8 ++---
 .../runtime/distributed/WorkerGroupMember.java  |  9 +++---
 .../distributed/WorkerRebalanceListener.java    |  9 +++---
 .../kafka/connect/runtime/rest/RestServer.java  |  9 +++---
 .../runtime/rest/entities/ConfigInfo.java       | 15 +++++----
 .../runtime/rest/entities/ConfigInfos.java      | 15 +++++----
 .../runtime/rest/entities/ConfigKeyInfo.java    | 15 +++++----
 .../runtime/rest/entities/ConfigValueInfo.java  | 15 +++++----
 .../runtime/rest/entities/ConnectorInfo.java    |  9 +++---
 .../rest/entities/ConnectorPluginInfo.java      | 27 +++++++++-------
 .../rest/entities/ConnectorStateInfo.java       | 14 ++++-----
 .../rest/entities/CreateConnectorRequest.java   |  9 +++---
 .../runtime/rest/entities/ErrorMessage.java     |  9 +++---
 .../runtime/rest/entities/ServerInfo.java       |  9 +++---
 .../connect/runtime/rest/entities/TaskInfo.java |  9 +++---
 .../rest/errors/BadRequestException.java        | 14 ++++-----
 .../rest/errors/ConnectExceptionMapper.java     |  9 +++---
 .../rest/errors/ConnectRestException.java       |  9 +++---
 .../resources/ConnectorPluginsResource.java     |  9 +++---
 .../rest/resources/ConnectorsResource.java      |  9 +++---
 .../runtime/rest/resources/RootResource.java    |  9 +++---
 .../runtime/standalone/StandaloneConfig.java    |  9 +++---
 .../runtime/standalone/StandaloneHerder.java    | 15 +++++----
 .../connect/storage/ConfigBackingStore.java     | 14 ++++-----
 .../connect/storage/FileOffsetBackingStore.java | 15 +++++----
 .../storage/KafkaConfigBackingStore.java        | 15 +++++----
 .../storage/KafkaOffsetBackingStore.java        |  9 +++---
 .../storage/KafkaStatusBackingStore.java        | 14 ++++-----
 .../storage/MemoryConfigBackingStore.java       | 14 ++++-----
 .../storage/MemoryOffsetBackingStore.java       | 15 +++++----
 .../storage/MemoryStatusBackingStore.java       | 14 ++++-----
 .../connect/storage/OffsetBackingStore.java     | 15 +++++----
 .../storage/OffsetStorageReaderImpl.java        | 15 +++++----
 .../connect/storage/OffsetStorageWriter.java    | 15 +++++----
 .../kafka/connect/storage/OffsetUtils.java      |  9 +++---
 .../connect/storage/StatusBackingStore.java     | 14 ++++-----
 .../kafka/connect/tools/MockConnector.java      | 14 ++++-----
 .../kafka/connect/tools/MockSinkConnector.java  | 14 ++++-----
 .../kafka/connect/tools/MockSinkTask.java       | 14 ++++-----
 .../connect/tools/MockSourceConnector.java      | 14 ++++-----
 .../kafka/connect/tools/MockSourceTask.java     | 14 ++++-----
 .../connect/tools/SchemaSourceConnector.java    |  9 +++---
 .../kafka/connect/tools/SchemaSourceTask.java   |  9 +++---
 .../kafka/connect/tools/TransformationDoc.java  | 15 +++++----
 .../connect/tools/VerifiableSinkConnector.java  |  9 +++---
 .../kafka/connect/tools/VerifiableSinkTask.java |  9 +++---
 .../tools/VerifiableSourceConnector.java        |  9 +++---
 .../connect/tools/VerifiableSourceTask.java     |  9 +++---
 .../org/apache/kafka/connect/util/Callback.java | 15 +++++----
 .../apache/kafka/connect/util/ConnectUtils.java | 14 ++++-----
 .../kafka/connect/util/ConnectorTaskId.java     | 15 +++++----
 .../connect/util/ConvertingFutureCallback.java  |  9 +++---
 .../kafka/connect/util/FutureCallback.java      | 15 +++++----
 .../kafka/connect/util/KafkaBasedLog.java       |  9 +++---
 .../kafka/connect/util/ReflectionsUtil.java     | 30 +++++++++---------
 .../kafka/connect/util/ShutdownableThread.java  | 15 +++++----
 .../apache/kafka/connect/util/SinkUtils.java    | 14 ++++-----
 .../org/apache/kafka/connect/util/Table.java    | 14 ++++-----
 .../connect/runtime/AbstractHerderTest.java     | 14 ++++-----
 .../connect/runtime/ConnectorConfigTest.java    | 15 +++++----
 .../runtime/SourceTaskOffsetCommitterTest.java  | 15 +++++----
 .../connect/runtime/WorkerConnectorTest.java    | 14 ++++-----
 .../connect/runtime/WorkerSinkTaskTest.java     |  9 +++---
 .../runtime/WorkerSinkTaskThreadedTest.java     | 15 +++++----
 .../connect/runtime/WorkerSourceTaskTest.java   | 15 +++++----
 .../kafka/connect/runtime/WorkerTaskTest.java   | 14 ++++-----
 .../kafka/connect/runtime/WorkerTest.java       | 15 +++++----
 .../distributed/DistributedHerderTest.java      |  9 +++---
 .../distributed/WorkerCoordinatorTest.java      |  8 ++---
 .../connect/runtime/rest/RestServerTest.java    |  9 +++---
 .../resources/ConnectorPluginsResourceTest.java |  9 +++---
 .../rest/resources/ConnectorsResourceTest.java  |  9 +++---
 .../standalone/StandaloneHerderTest.java        | 15 +++++----
 .../storage/FileOffsetBackingStoreTest.java     | 15 +++++----
 .../storage/KafkaConfigBackingStoreTest.java    |  9 +++---
 .../storage/KafkaOffsetBackingStoreTest.java    |  9 +++---
 .../storage/KafkaStatusBackingStoreTest.java    | 14 ++++-----
 .../storage/MemoryStatusBackingStoreTest.java   | 14 ++++-----
 .../storage/OffsetStorageWriterTest.java        | 15 +++++----
 .../util/ByteArrayProducerRecordEquals.java     |  9 +++---
 .../kafka/connect/util/KafkaBasedLogTest.java   |  9 +++---
 .../org/apache/kafka/connect/util/MockTime.java |  8 ++---
 .../connect/util/ShutdownableThreadTest.java    | 15 +++++----
 .../apache/kafka/connect/util/TableTest.java    | 14 ++++-----
 .../TestBackgroundThreadExceptionHandler.java   | 15 +++++----
 .../apache/kafka/connect/util/TestFuture.java   |  9 +++---
 .../apache/kafka/connect/util/ThreadedTest.java | 15 +++++----
 .../kafka/connect/transforms/ExtractField.java  | 15 +++++----
 .../kafka/connect/transforms/HoistField.java    | 15 +++++----
 .../kafka/connect/transforms/InsertField.java   | 15 +++++----
 .../kafka/connect/transforms/MaskField.java     | 15 +++++----
 .../kafka/connect/transforms/RegexRouter.java   | 15 +++++----
 .../kafka/connect/transforms/ReplaceField.java  | 15 +++++----
 .../connect/transforms/SetSchemaMetadata.java   | 15 +++++----
 .../connect/transforms/TimestampRouter.java     | 15 +++++----
 .../kafka/connect/transforms/ValueToKey.java    | 15 +++++----
 .../transforms/util/NonEmptyListValidator.java  | 15 +++++----
 .../connect/transforms/util/RegexValidator.java | 15 +++++----
 .../connect/transforms/util/Requirements.java   | 15 +++++----
 .../connect/transforms/util/SchemaUtil.java     | 15 +++++----
 .../connect/transforms/util/SimpleConfig.java   | 15 +++++----
 .../connect/transforms/ExtractFieldTest.java    | 15 +++++----
 .../connect/transforms/HoistFieldTest.java      | 15 +++++----
 .../connect/transforms/InsertFieldTest.java     | 15 +++++----
 .../kafka/connect/transforms/MaskFieldTest.java | 15 +++++----
 .../connect/transforms/RegexRouterTest.java     | 15 +++++----
 .../connect/transforms/ReplaceFieldTest.java    | 15 +++++----
 .../transforms/SetSchemaMetadataTest.java       | 15 +++++----
 .../connect/transforms/TimestampRouterTest.java | 15 +++++----
 .../connect/transforms/ValueToKeyTest.java      | 15 +++++----
 .../kafka/consumer/ConsumerConnector.scala      |  9 +++---
 .../javaapi/consumer/ConsumerConnector.java     |  9 +++---
 .../consumer/ConsumerRebalanceListener.java     |  7 ++---
 .../main/scala/kafka/metrics/KafkaTimer.scala   |  7 ++---
 .../main/scala/kafka/server/LeaderElector.scala |  6 ++--
 .../main/scala/kafka/tools/StreamsResetter.java | 12 +++----
 .../src/main/java/kafka/examples/Consumer.java  |  6 ++--
 .../examples/KafkaConsumerProducerDemo.java     |  6 ++--
 .../java/kafka/examples/KafkaProperties.java    | 12 +++----
 .../src/main/java/kafka/examples/Producer.java  |  6 ++--
 .../java/kafka/examples/SimpleConsumerDemo.java |  6 ++--
 .../kafka/log4jappender/KafkaLog4jAppender.java |  7 ++---
 .../log4jappender/KafkaLog4jAppenderTest.java   |  6 ++--
 .../log4jappender/MockKafkaLog4jAppender.java   |  6 ++--
 .../examples/pageview/JsonPOJODeserializer.java | 14 ++++-----
 .../examples/pageview/JsonPOJOSerializer.java   | 14 ++++-----
 .../pageview/JsonTimestampExtractor.java        |  7 ++---
 .../examples/pageview/PageViewTypedDemo.java    |  7 ++---
 .../examples/pageview/PageViewUntypedDemo.java  |  7 ++---
 .../kafka/streams/examples/pipe/PipeDemo.java   |  7 ++---
 .../examples/wordcount/WordCountDemo.java       |  7 ++---
 .../wordcount/WordCountProcessorDemo.java       |  7 ++---
 .../kafka/streams/KafkaClientSupplier.java      | 13 ++++----
 .../org/apache/kafka/streams/KafkaStreams.java  | 13 ++++----
 .../java/org/apache/kafka/streams/KeyValue.java |  7 ++---
 .../org/apache/kafka/streams/StreamsConfig.java | 13 ++++----
 .../apache/kafka/streams/StreamsMetrics.java    |  7 ++---
 .../errors/InvalidStateStoreException.java      | 24 +++++++-------
 .../kafka/streams/errors/LockException.java     | 24 +++++++-------
 .../streams/errors/ProcessorStateException.java |  7 ++---
 .../kafka/streams/errors/StreamsException.java  |  9 +++---
 .../streams/errors/TaskAssignmentException.java |  6 ++--
 .../streams/errors/TaskIdFormatException.java   |  7 ++---
 .../errors/TopologyBuilderException.java        |  7 ++---
 .../kafka/streams/kstream/Aggregator.java       | 13 ++++----
 .../kafka/streams/kstream/ForeachAction.java    | 12 +++----
 .../kafka/streams/kstream/GlobalKTable.java     | 13 ++++----
 .../kafka/streams/kstream/Initializer.java      |  7 ++---
 .../kafka/streams/kstream/JoinWindows.java      | 13 ++++----
 .../kafka/streams/kstream/KGroupedStream.java   | 28 +++++++++--------
 .../kafka/streams/kstream/KGroupedTable.java    |  7 ++---
 .../apache/kafka/streams/kstream/KStream.java   | 12 +++----
 .../kafka/streams/kstream/KStreamBuilder.java   |  7 ++---
 .../apache/kafka/streams/kstream/KTable.java    |  7 ++---
 .../kafka/streams/kstream/KeyValueMapper.java   | 12 +++----
 .../apache/kafka/streams/kstream/Merger.java    |  7 ++---
 .../apache/kafka/streams/kstream/Predicate.java |  6 ++--
 .../apache/kafka/streams/kstream/Reducer.java   | 13 ++++----
 .../kafka/streams/kstream/SessionWindows.java   | 12 +++----
 .../kafka/streams/kstream/TimeWindows.java      | 13 ++++----
 .../kafka/streams/kstream/Transformer.java      |  7 ++---
 .../streams/kstream/TransformerSupplier.java    |  7 ++---
 .../kafka/streams/kstream/UnlimitedWindows.java | 13 ++++----
 .../kafka/streams/kstream/ValueJoiner.java      |  6 ++--
 .../kafka/streams/kstream/ValueMapper.java      |  6 ++--
 .../kafka/streams/kstream/ValueTransformer.java |  7 ++---
 .../kstream/ValueTransformerSupplier.java       |  6 ++--
 .../apache/kafka/streams/kstream/Window.java    | 12 +++----
 .../apache/kafka/streams/kstream/Windowed.java  |  7 ++---
 .../apache/kafka/streams/kstream/Windows.java   | 12 +++----
 ...ractKTableKTableJoinValueGetterSupplier.java | 12 +++----
 .../kstream/internals/AbstractStream.java       |  7 ++---
 .../kstream/internals/CacheFlushListener.java   | 12 +++----
 .../kafka/streams/kstream/internals/Change.java |  7 ++---
 .../kstream/internals/ChangedDeserializer.java  |  7 ++---
 .../kstream/internals/ChangedSerializer.java    |  7 ++---
 .../internals/ForwardingCacheFlushListener.java | 12 +++----
 .../kstream/internals/GlobalKTableImpl.java     | 12 +++----
 .../kstream/internals/KGroupedStreamImpl.java   | 28 +++++++++--------
 .../kstream/internals/KGroupedTableImpl.java    |  7 ++---
 .../internals/KStreamAggProcessorSupplier.java  |  7 ++---
 .../kstream/internals/KStreamAggregate.java     |  7 ++---
 .../kstream/internals/KStreamBranch.java        |  7 ++---
 .../kstream/internals/KStreamFilter.java        |  7 ++---
 .../kstream/internals/KStreamFlatMap.java       |  7 ++---
 .../kstream/internals/KStreamFlatMapValues.java |  7 ++---
 .../kstream/internals/KStreamForeach.java       |  7 ++---
 .../internals/KStreamGlobalKTableJoin.java      | 13 ++++----
 .../streams/kstream/internals/KStreamImpl.java  | 13 ++++----
 .../kstream/internals/KStreamJoinWindow.java    |  7 ++---
 .../kstream/internals/KStreamKStreamJoin.java   | 13 ++++----
 .../kstream/internals/KStreamKTableJoin.java    | 13 ++++----
 .../internals/KStreamKTableJoinProcessor.java   | 12 +++----
 .../streams/kstream/internals/KStreamMap.java   |  7 ++---
 .../kstream/internals/KStreamMapValues.java     |  7 ++---
 .../kstream/internals/KStreamPassThrough.java   |  7 ++---
 .../streams/kstream/internals/KStreamPeek.java  |  7 ++---
 .../kstream/internals/KStreamReduce.java        |  7 ++---
 .../KStreamSessionWindowAggregate.java          | 13 ++++----
 .../kstream/internals/KStreamTransform.java     |  7 ++---
 .../internals/KStreamTransformValues.java       |  7 ++---
 .../internals/KStreamWindowAggregate.java       |  7 ++---
 .../kstream/internals/KStreamWindowReduce.java  |  7 ++---
 .../kstream/internals/KTableAggregate.java      |  7 ++---
 .../streams/kstream/internals/KTableFilter.java |  7 ++---
 .../streams/kstream/internals/KTableImpl.java   | 13 ++++----
 .../internals/KTableKTableAbstractJoin.java     |  7 ++---
 .../kstream/internals/KTableKTableJoin.java     | 13 ++++----
 .../internals/KTableKTableJoinMerger.java       |  7 ++---
 .../internals/KTableKTableJoinValueGetter.java  | 12 +++----
 .../kstream/internals/KTableKTableLeftJoin.java | 13 ++++----
 .../KTableKTableLeftJoinValueGetter.java        | 12 +++----
 .../internals/KTableKTableOuterJoin.java        | 13 ++++----
 .../internals/KTableKTableRightJoin.java        | 13 ++++----
 .../kstream/internals/KTableMapValues.java      |  7 ++---
 .../internals/KTableProcessorSupplier.java      |  7 ++---
 .../streams/kstream/internals/KTableReduce.java |  7 ++---
 .../kstream/internals/KTableRepartitionMap.java |  7 ++---
 .../streams/kstream/internals/KTableSource.java |  7 ++---
 .../KTableSourceValueGetterSupplier.java        |  7 ++---
 .../kstream/internals/KTableValueGetter.java    |  7 ++---
 .../internals/KTableValueGetterSupplier.java    |  7 ++---
 .../kstream/internals/KeyValuePrinter.java      | 13 ++++----
 .../kstream/internals/SessionKeySerde.java      | 12 +++----
 .../kstream/internals/SessionWindow.java        | 32 +++++++++----------
 .../streams/kstream/internals/TimeWindow.java   |  6 ++--
 .../kstream/internals/TupleForwarder.java       |  7 ++---
 .../kstream/internals/UnlimitedWindow.java      | 12 +++----
 .../kstream/internals/WindowedDeserializer.java |  7 ++---
 .../kstream/internals/WindowedSerializer.java   |  7 ++---
 .../internals/WindowedStreamPartitioner.java    |  6 ++--
 .../streams/processor/AbstractProcessor.java    |  4 +--
 .../processor/DefaultPartitionGrouper.java      |  7 ++---
 .../ExtractRecordMetadataTimestamp.java         |  7 ++---
 .../processor/FailOnInvalidTimestamp.java       |  7 ++---
 .../processor/LogAndSkipOnInvalidTimestamp.java |  7 ++---
 .../streams/processor/PartitionGrouper.java     |  7 ++---
 .../kafka/streams/processor/Processor.java      |  7 ++---
 .../streams/processor/ProcessorContext.java     |  7 ++---
 .../streams/processor/ProcessorSupplier.java    |  7 ++---
 .../streams/processor/StateRestoreCallback.java |  7 ++---
 .../kafka/streams/processor/StateStore.java     | 13 ++++----
 .../streams/processor/StateStoreSupplier.java   | 13 ++++----
 .../streams/processor/StreamPartitioner.java    |  6 ++--
 .../apache/kafka/streams/processor/TaskId.java  |  7 ++---
 .../streams/processor/TimestampExtractor.java   |  7 ++---
 .../streams/processor/TopologyBuilder.java      | 13 ++++----
 .../UsePreviousTimeOnInvalidTimestamp.java      |  7 ++---
 .../processor/WallclockTimestampExtractor.java  |  7 ++---
 .../internals/AbstractProcessorContext.java     | 12 +++----
 .../processor/internals/AbstractTask.java       |  7 ++---
 .../processor/internals/ChangelogReader.java    | 12 +++----
 .../processor/internals/Checkpointable.java     | 12 +++----
 .../internals/DefaultKafkaClientSupplier.java   | 13 ++++----
 .../internals/DefaultStreamPartitioner.java     | 12 +++----
 .../internals/GlobalProcessorContextImpl.java   |  7 ++---
 .../internals/GlobalStateMaintainer.java        | 12 +++----
 .../processor/internals/GlobalStateManager.java | 12 +++----
 .../internals/GlobalStateManagerImpl.java       | 12 +++----
 .../internals/GlobalStateUpdateTask.java        | 12 +++----
 .../processor/internals/GlobalStreamThread.java | 12 +++----
 .../internals/InternalProcessorContext.java     | 12 +++----
 .../internals/InternalTopicConfig.java          | 12 +++----
 .../internals/InternalTopicManager.java         |  7 ++---
 .../internals/MinTimestampTracker.java          |  7 ++---
 .../processor/internals/PartitionGroup.java     | 13 ++++----
 .../internals/ProcessorContextImpl.java         |  7 ++---
 .../processor/internals/ProcessorNode.java      | 13 ++++----
 .../internals/ProcessorRecordContext.java       | 12 +++----
 .../internals/ProcessorStateManager.java        | 13 ++++----
 .../processor/internals/ProcessorTopology.java  |  7 ++---
 .../processor/internals/PunctuationQueue.java   |  7 ++---
 .../internals/PunctuationSchedule.java          |  7 ++---
 .../streams/processor/internals/Punctuator.java |  7 ++---
 .../streams/processor/internals/QuickUnion.java |  7 ++---
 .../processor/internals/RecordCollector.java    | 12 +++----
 .../internals/RecordCollectorImpl.java          |  7 ++---
 .../processor/internals/RecordContext.java      | 12 +++----
 .../processor/internals/RecordDeserializer.java | 12 +++----
 .../processor/internals/RecordQueue.java        |  7 ++---
 .../streams/processor/internals/SinkNode.java   |  7 ++---
 .../streams/processor/internals/SourceNode.java |  7 ++---
 .../internals/SourceNodeRecordDeserializer.java | 12 +++----
 .../streams/processor/internals/Stamped.java    |  7 ++---
 .../processor/internals/StampedRecord.java      |  7 ++---
 .../processor/internals/StandbyContextImpl.java |  7 ++---
 .../processor/internals/StandbyTask.java        | 13 ++++----
 .../processor/internals/StateDirectory.java     | 12 +++----
 .../processor/internals/StateManager.java       | 12 +++----
 .../processor/internals/StateRestorer.java      | 12 +++----
 .../internals/StoreChangelogReader.java         | 12 +++----
 .../internals/StreamPartitionAssignor.java      |  7 ++---
 .../streams/processor/internals/StreamTask.java | 13 ++++----
 .../processor/internals/StreamThread.java       | 13 ++++----
 .../processor/internals/StreamsKafkaClient.java | 23 ++++++++------
 .../internals/StreamsMetadataState.java         | 12 +++----
 .../processor/internals/StreamsMetricsImpl.java | 13 ++++----
 .../processor/internals/TimestampTracker.java   |  7 ++---
 .../internals/assignment/AssignmentInfo.java    | 13 ++++----
 .../internals/assignment/ClientState.java       |  7 ++---
 .../assignment/StickyTaskAssignor.java          | 12 +++----
 .../internals/assignment/SubscriptionInfo.java  | 13 ++++----
 .../internals/assignment/TaskAssignor.java      | 12 +++----
 .../apache/kafka/streams/state/HostInfo.java    | 12 +++----
 .../kafka/streams/state/KeyValueIterator.java   | 33 +++++++++-----------
 .../kafka/streams/state/KeyValueStore.java      | 33 +++++++++-----------
 .../kafka/streams/state/QueryableStoreType.java | 24 +++++++-------
 .../streams/state/QueryableStoreTypes.java      | 24 +++++++-------
 .../streams/state/ReadOnlyKeyValueStore.java    | 24 +++++++-------
 .../streams/state/ReadOnlySessionStore.java     | 12 +++----
 .../streams/state/ReadOnlyWindowStore.java      | 24 +++++++-------
 .../streams/state/RocksDBConfigSetter.java      | 12 +++----
 .../kafka/streams/state/SessionStore.java       | 12 +++----
 .../apache/kafka/streams/state/StateSerdes.java |  4 +--
 .../org/apache/kafka/streams/state/Stores.java  |  4 +--
 .../kafka/streams/state/StreamsMetadata.java    | 12 +++----
 .../apache/kafka/streams/state/WindowStore.java | 33 +++++++++-----------
 .../streams/state/WindowStoreIterator.java      | 33 +++++++++-----------
 .../AbstractMergedSortedCacheStoreIterator.java | 33 +++++++++-----------
 .../state/internals/AbstractStoreSupplier.java  | 12 +++----
 .../state/internals/CachedStateStore.java       | 12 +++----
 .../state/internals/CachingKeyValueStore.java   | 12 +++----
 .../state/internals/CachingSessionStore.java    | 12 +++----
 .../state/internals/CachingWindowStore.java     | 12 +++----
 .../ChangeLoggingKeyValueBytesStore.java        | 12 +++----
 .../internals/ChangeLoggingKeyValueStore.java   | 12 +++----
 .../ChangeLoggingSegmentedBytesStore.java       | 12 +++----
 .../CompositeReadOnlyKeyValueStore.java         | 28 +++++++++--------
 .../CompositeReadOnlySessionStore.java          | 12 +++----
 .../internals/CompositeReadOnlyWindowStore.java | 24 +++++++-------
 .../DelegatingPeekingKeyValueIterator.java      | 12 +++----
 .../internals/GlobalStateStoreProvider.java     | 12 +++----
 .../state/internals/HasNextCondition.java       | 12 +++----
 .../internals/InMemoryKeyValueLoggedStore.java  |  7 ++---
 .../state/internals/InMemoryKeyValueStore.java  | 24 +++++++-------
 .../InMemoryKeyValueStoreSupplier.java          |  7 ++---
 .../InMemoryLRUCacheStoreSupplier.java          |  7 ++---
 .../streams/state/internals/LRUCacheEntry.java  |  8 ++---
 .../streams/state/internals/MemoryLRUCache.java |  4 +--
 .../internals/MemoryNavigableLRUCache.java      |  4 +--
 .../MergedSortedCacheKeyValueStoreIterator.java | 12 +++----
 .../MergedSortedCacheSessionStoreIterator.java  | 32 +++++++++----------
 .../MergedSortedCacheWindowStoreIterator.java   | 12 +++----
 .../state/internals/MeteredKeyValueStore.java   |  7 ++---
 .../internals/MeteredSegmentedBytesStore.java   |  7 ++---
 .../streams/state/internals/NamedCache.java     | 12 +++----
 .../state/internals/OffsetCheckpoint.java       | 13 ++++----
 .../internals/PeekingKeyValueIterator.java      | 12 +++----
 .../state/internals/QueryableStoreProvider.java | 28 +++++++++--------
 .../internals/RocksDBKeyValueStoreSupplier.java |  7 ++---
 .../internals/RocksDBSegmentedBytesStore.java   | 12 +++----
 .../state/internals/RocksDBSessionStore.java    | 12 +++----
 .../internals/RocksDBSessionStoreSupplier.java  | 13 ++++----
 .../streams/state/internals/RocksDBStore.java   |  7 ++---
 .../state/internals/RocksDBWindowStore.java     | 33 +++++++++-----------
 .../internals/RocksDBWindowStoreSupplier.java   |  7 ++---
 .../kafka/streams/state/internals/Segment.java  | 12 +++----
 .../state/internals/SegmentIterator.java        | 12 +++----
 .../state/internals/SegmentedBytesStore.java    | 12 +++----
 .../kafka/streams/state/internals/Segments.java | 12 +++----
 .../internals/SerializedKeyValueIterator.java   | 12 +++----
 .../state/internals/SessionKeySchema.java       | 12 +++----
 .../state/internals/StateStoreProvider.java     | 24 +++++++-------
 .../state/internals/StoreChangeLogger.java      |  7 ++---
 .../StreamThreadStateStoreProvider.java         | 24 +++++++-------
 .../streams/state/internals/ThreadCache.java    |  8 ++---
 .../state/internals/WindowKeySchema.java        | 12 +++----
 .../state/internals/WindowStoreSupplier.java    | 12 +++----
 .../state/internals/WindowStoreUtils.java       | 33 +++++++++-----------
 .../internals/WrappedSessionStoreIterator.java  | 32 +++++++++----------
 .../state/internals/WrappedStateStore.java      | 32 +++++++++----------
 .../internals/WrappedWindowStoreIterator.java   | 32 +++++++++----------
 .../state/internals/WrappingStoreProvider.java  | 24 +++++++-------
 .../apache/kafka/streams/KafkaStreamsTest.java  | 13 ++++----
 .../org/apache/kafka/streams/KeyValueTest.java  | 13 ++++----
 .../apache/kafka/streams/StreamsConfigTest.java | 13 ++++----
 .../integration/FanoutIntegrationTest.java      | 13 ++++----
 .../GlobalKTableIntegrationTest.java            | 28 +++++++++--------
 .../InternalTopicIntegrationTest.java           | 12 +++----
 .../integration/JoinIntegrationTest.java        | 12 +++----
 .../KStreamAggregationDedupIntegrationTest.java | 24 ++++++++------
 .../KStreamAggregationIntegrationTest.java      | 28 +++++++++--------
 .../KStreamKTableJoinIntegrationTest.java       | 28 +++++++++--------
 .../integration/KStreamRepartitionJoinTest.java | 28 +++++++++--------
 ...eamsFineGrainedAutoResetIntegrationTest.java | 30 +++++++++---------
 .../KTableKTableJoinIntegrationTest.java        | 28 +++++++++--------
 .../QueryableStateIntegrationTest.java          | 28 +++++++++--------
 .../integration/RegexSourceIntegrationTest.java | 30 +++++++++---------
 .../integration/ResetIntegrationTest.java       | 13 ++++----
 .../integration/utils/EmbeddedKafkaCluster.java | 13 ++++----
 .../integration/utils/IntegrationTestUtils.java | 13 ++++----
 .../integration/utils/KafkaEmbedded.java        | 13 ++++----
 .../kafka/streams/kstream/JoinWindowsTest.java  | 33 +++++++++-----------
 .../streams/kstream/KStreamBuilderTest.java     |  7 ++---
 .../streams/kstream/SessionWindowsTest.java     | 33 +++++++++-----------
 .../kafka/streams/kstream/TimeWindowsTest.java  | 33 +++++++++-----------
 .../streams/kstream/UnlimitedWindowsTest.java   | 33 +++++++++-----------
 .../kafka/streams/kstream/WindowTest.java       | 32 +++++++++----------
 .../kafka/streams/kstream/WindowsTest.java      | 12 +++----
 .../internals/GlobalKTableJoinsTest.java        | 12 +++----
 .../internals/KGroupedStreamImplTest.java       | 13 ++++----
 .../internals/KGroupedTableImplTest.java        |  7 ++---
 .../kstream/internals/KStreamBranchTest.java    |  7 ++---
 .../kstream/internals/KStreamFilterTest.java    |  7 ++---
 .../kstream/internals/KStreamFlatMapTest.java   |  7 ++---
 .../internals/KStreamFlatMapValuesTest.java     |  7 ++---
 .../kstream/internals/KStreamForeachTest.java   |  7 ++---
 .../kstream/internals/KStreamImplTest.java      |  7 ++---
 .../internals/KStreamKStreamJoinTest.java       |  7 ++---
 .../internals/KStreamKStreamLeftJoinTest.java   | 13 ++++----
 .../internals/KStreamKTableJoinTest.java        | 13 ++++----
 .../internals/KStreamKTableLeftJoinTest.java    |  7 ++---
 .../kstream/internals/KStreamMapTest.java       |  7 ++---
 .../kstream/internals/KStreamMapValuesTest.java |  7 ++---
 .../kstream/internals/KStreamPeekTest.java      | 19 ++++++-----
 .../kstream/internals/KStreamSelectKeyTest.java |  9 ++----
 ...reamSessionWindowAggregateProcessorTest.java | 13 ++++----
 .../kstream/internals/KStreamTransformTest.java |  7 ++---
 .../internals/KStreamTransformValuesTest.java   |  7 ++---
 .../internals/KStreamWindowAggregateTest.java   | 13 ++++----
 .../kstream/internals/KTableAggregateTest.java  |  7 ++---
 .../kstream/internals/KTableFilterTest.java     |  7 ++---
 .../kstream/internals/KTableForeachTest.java    |  7 ++---
 .../kstream/internals/KTableImplTest.java       |  7 ++---
 .../kstream/internals/KTableKTableJoinTest.java | 13 ++++----
 .../internals/KTableKTableLeftJoinTest.java     | 13 ++++----
 .../internals/KTableKTableOuterJoinTest.java    | 13 ++++----
 .../kstream/internals/KTableMapKeysTest.java    |  7 ++---
 .../kstream/internals/KTableMapValuesTest.java  |  7 ++---
 .../kstream/internals/KTableSourceTest.java     |  7 ++---
 .../internals/KeyValuePrinterProcessorTest.java | 13 ++++----
 .../kstream/internals/SessionKeySerdeTest.java  | 13 ++++----
 .../kstream/internals/SessionWindowTest.java    | 32 +++++++++----------
 .../kstream/internals/TimeWindowTest.java       | 32 +++++++++----------
 .../kstream/internals/UnlimitedWindowTest.java  | 32 +++++++++----------
 .../WindowedStreamPartitionerTest.java          |  7 ++---
 .../kafka/streams/perf/SimpleBenchmark.java     |  7 ++---
 .../processor/DefaultPartitionGrouperTest.java  |  7 ++---
 .../processor/FailOnInvalidTimestampTest.java   | 12 +++----
 .../LogAndSkipOnInvalidTimestampTest.java       | 12 +++----
 .../processor/TimestampExtractorTest.java       | 12 +++----
 .../streams/processor/TopologyBuilderTest.java  |  7 ++---
 .../UsePreviousTimeOnInvalidTimestampTest.java  | 12 +++----
 .../WallclockTimestampExtractorTest.java        | 12 +++----
 .../internals/AbstractProcessorContextTest.java | 13 ++++----
 .../processor/internals/AbstractTaskTest.java   | 13 ++++----
 .../CopartitionedTopicsValidatorTest.java       | 13 ++++----
 .../internals/GlobalStateManagerImplTest.java   | 13 ++++----
 .../internals/GlobalStateTaskTest.java          | 13 ++++----
 .../internals/GlobalStreamThreadTest.java       | 13 ++++----
 .../internals/InternalTopicConfigTest.java      | 13 ++++----
 .../internals/InternalTopicManagerTest.java     | 13 ++++----
 .../internals/MinTimestampTrackerTest.java      |  7 ++---
 .../processor/internals/MockStreamsMetrics.java | 12 +++----
 .../processor/internals/PartitionGroupTest.java | 13 ++++----
 .../processor/internals/ProcessorNodeTest.java  | 13 ++++----
 .../internals/ProcessorStateManagerTest.java    |  7 ++---
 .../internals/ProcessorTopologyTest.java        |  7 ++---
 .../internals/PunctuationQueueTest.java         |  7 ++---
 .../processor/internals/QuickUnionTest.java     |  7 ++---
 .../internals/RecordCollectorTest.java          | 16 ++++------
 .../processor/internals/RecordContextStub.java  | 12 +++----
 .../processor/internals/RecordQueueTest.java    | 13 ++++----
 .../SingleGroupPartitionGrouperStub.java        | 13 ++++----
 .../processor/internals/SinkNodeTest.java       | 13 ++++----
 .../SourceNodeRecordDeserializerTest.java       | 13 ++++----
 .../processor/internals/StandbyTaskTest.java    |  7 ++---
 .../processor/internals/StateConsumerTest.java  | 13 ++++----
 .../processor/internals/StateDirectoryTest.java | 13 ++++----
 .../processor/internals/StateManagerStub.java   | 12 +++----
 .../processor/internals/StateRestorerTest.java  | 13 ++++----
 .../internals/StoreChangelogReaderTest.java     | 13 ++++----
 .../internals/StreamPartitionAssignorTest.java  |  7 ++---
 .../processor/internals/StreamTaskTest.java     |  7 ++---
 .../processor/internals/StreamThreadTest.java   | 13 ++++----
 .../internals/StreamsKafkaClientTest.java       | 29 +++++++++--------
 .../internals/StreamsMetadataStateTest.java     | 12 +++----
 .../internals/StreamsMetricsImplTest.java       | 12 +++----
 .../assignment/AssignmentInfoTest.java          |  7 ++---
 .../internals/assignment/ClientStateTest.java   | 13 ++++----
 .../assignment/StickyTaskAssignorTest.java      | 12 +++----
 .../assignment/SubscriptionInfoTest.java        |  7 ++---
 .../streams/state/KeyValueStoreTestDriver.java  | 12 +++----
 .../kafka/streams/state/NoOpWindowStore.java    | 12 +++----
 .../apache/kafka/streams/state/StoresTest.java  | 13 ++++----
 .../internals/AbstractKeyValueStoreTest.java    |  7 ++---
 .../internals/CachingKeyValueStoreTest.java     | 13 ++++----
 .../internals/CachingSessionStoreTest.java      | 13 ++++----
 .../state/internals/CachingWindowStoreTest.java | 13 ++++----
 .../ChangeLoggingKeyValueBytesStoreTest.java    | 12 +++----
 .../ChangeLoggingKeyValueStoreTest.java         | 12 +++----
 .../ChangeLoggingSegmentedBytesStoreTest.java   | 13 ++++----
 .../CompositeReadOnlyKeyValueStoreTest.java     | 24 +++++++-------
 .../CompositeReadOnlySessionStoreTest.java      | 13 ++++----
 .../CompositeReadOnlyWindowStoreTest.java       | 24 +++++++-------
 .../DelegatingPeekingKeyValueIteratorTest.java  | 13 ++++----
 .../internals/GlobalStateStoreProviderTest.java | 13 ++++----
 .../internals/InMemoryKeyValueStoreTest.java    |  6 ++--
 .../internals/InMemoryLRUCacheStoreTest.java    |  4 +--
 ...gedSortedCacheKeyValueStoreIteratorTest.java | 13 ++++----
 ...tedCacheWrappedSessionStoreIteratorTest.java | 13 ++++----
 ...rtedCacheWrappedWindowStoreIteratorTest.java | 13 ++++----
 .../MeteredSegmentedBytesStoreTest.java         | 13 ++++----
 .../streams/state/internals/NamedCacheTest.java | 13 ++++----
 .../state/internals/OffsetCheckpointTest.java   | 13 ++++----
 .../internals/QueryableStoreProviderTest.java   | 24 +++++++-------
 .../internals/ReadOnlyWindowStoreStub.java      | 24 +++++++-------
 .../RocksDBKeyValueStoreSupplierTest.java       | 13 ++++----
 .../internals/RocksDBKeyValueStoreTest.java     |  6 ++--
 .../RocksDBSegmentedBytesStoreTest.java         | 13 ++++----
 .../RocksDBSessionStoreSupplierTest.java        | 13 ++++----
 .../internals/RocksDBSessionStoreTest.java      | 13 ++++----
 .../RocksDBWindowStoreSupplierTest.java         | 13 ++++----
 .../state/internals/RocksDBWindowStoreTest.java |  7 ++---
 .../state/internals/SegmentIteratorTest.java    | 13 ++++----
 .../streams/state/internals/SegmentsTest.java   | 13 ++++----
 .../SerializedKeyValueIteratorTest.java         | 13 ++++----
 .../state/internals/StateStoreTestUtils.java    | 12 +++----
 .../state/internals/StoreChangeLoggerTest.java  | 33 +++++++++-----------
 .../StreamThreadStateStoreProviderTest.java     | 24 +++++++-------
 .../state/internals/ThreadCacheTest.java        |  8 ++---
 .../state/internals/WindowStoreUtilsTest.java   | 32 +++++++++----------
 .../internals/WrappingStoreProviderTest.java    | 12 +++----
 .../streams/tests/BrokerCompatibilityTest.java  |  6 ++--
 .../streams/tests/ShutdownDeadlockTest.java     | 12 +++----
 .../kafka/streams/tests/SmokeTestClient.java    |  7 ++---
 .../kafka/streams/tests/SmokeTestDriver.java    |  7 ++---
 .../kafka/streams/tests/SmokeTestUtil.java      |  7 ++---
 .../kafka/streams/tests/StreamsSmokeTest.java   |  7 ++---
 .../kafka/test/GlobalStateManagerStub.java      | 12 +++----
 .../apache/kafka/test/KStreamTestDriver.java    |  7 ++---
 .../kafka/test/KTableValueGetterStub.java       | 12 +++----
 .../apache/kafka/test/KeyValueIteratorStub.java | 12 +++----
 .../org/apache/kafka/test/MockAggregator.java   |  7 ++---
 .../apache/kafka/test/MockChangelogReader.java  | 12 +++----
 .../apache/kafka/test/MockClientSupplier.java   |  7 ++---
 .../org/apache/kafka/test/MockInitializer.java  |  7 ++---
 .../kafka/test/MockInternalTopicManager.java    |  7 ++---
 .../apache/kafka/test/MockKeyValueMapper.java   |  7 ++---
 .../apache/kafka/test/MockProcessorContext.java |  7 ++---
 .../apache/kafka/test/MockProcessorNode.java    |  7 ++---
 .../kafka/test/MockProcessorSupplier.java       |  7 ++---
 .../java/org/apache/kafka/test/MockReducer.java |  7 ++---
 .../apache/kafka/test/MockRestoreCallback.java  | 12 +++----
 .../apache/kafka/test/MockRestoreConsumer.java  | 12 +++----
 .../org/apache/kafka/test/MockSourceNode.java   |  7 ++---
 .../kafka/test/MockStateStoreSupplier.java      |  7 ++---
 .../kafka/test/MockTimestampExtractor.java      |  7 ++---
 .../org/apache/kafka/test/MockValueJoiner.java  |  7 ++---
 .../apache/kafka/test/NoOpProcessorContext.java | 12 +++----
 .../apache/kafka/test/NoOpReadOnlyStore.java    | 12 +++----
 .../apache/kafka/test/NoOpRecordCollector.java  | 12 +++----
 .../kafka/test/ProcessorTopologyTestDriver.java | 12 +++----
 .../kafka/test/ReadOnlySessionStoreStub.java    | 12 +++----
 .../kafka/test/SegmentedBytesStoreStub.java     | 12 +++----
 .../kafka/test/StateStoreProviderStub.java      | 24 +++++++-------
 .../org/apache/kafka/test/StreamsTestUtils.java | 28 +++++++++--------
 .../kafka/tools/ClientCompatibilityTest.java    | 12 +++----
 .../apache/kafka/tools/ProducerPerformance.java | 22 +++++++------
 .../apache/kafka/tools/ThroughputThrottler.java |  7 ++---
 .../apache/kafka/tools/VerifiableConsumer.java  |  7 ++---
 .../kafka/tools/VerifiableLog4jAppender.java    |  7 ++---
 .../apache/kafka/tools/VerifiableProducer.java  |  7 ++---
 1100 files changed, 7765 insertions(+), 7406 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/checkstyle/checkstyle.xml
----------------------------------------------------------------------
diff --git a/checkstyle/checkstyle.xml b/checkstyle/checkstyle.xml
index 25d6f2f..51b613d 100644
--- a/checkstyle/checkstyle.xml
+++ b/checkstyle/checkstyle.xml
@@ -24,8 +24,8 @@
   <module name="FileTabCharacter"/>
 
   <!-- header -->
-  <module name="RegexpHeader">
-    <property name="header" value="/\*\*\nLicensed to the Apache.*"/>
+  <module name="Header">
+    <property name="headerFile" value="checkstyle/java.header" />
   </module>
 
   <module name="TreeWalker">

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/checkstyle/java.header
----------------------------------------------------------------------
diff --git a/checkstyle/java.header b/checkstyle/java.header
new file mode 100644
index 0000000..45fd2d5
--- /dev/null
+++ b/checkstyle/java.header
@@ -0,0 +1,16 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java b/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
index 564b391..1111964 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java b/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
index 2dfbba6..715eae7 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java b/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
index 28eb72e..7d19ea4 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
  *
- * http://www.apache.org/licenses/LICENSE-2.0
+ *    http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java b/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
index 350f5a9..0ce7993 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
index 944b09d..5006ee2 100644
--- a/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
+++ b/clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
@@ -1,16 +1,19 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
  *
- * http://www.apache.org/licenses/LICENSE-2.0
+ *    http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.kafka.clients;
 
 import org.apache.kafka.common.protocol.SecurityProtocol;

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java b/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
index 18e7e18..62ffada 100644
--- a/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
+++ b/clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/d0e436c4/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java b/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
index f4f753e..06b8fed 100644
--- a/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
+++ b/clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
@@ -1,14 +1,18 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
- * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
- * to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
- * License. You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
- * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations under the License.
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package org.apache.kafka.clients;
 


Mime
View raw message