MINOR: improve license header check by providing head file instead of (prefix) header regex
Author: Matthias J. Sax <[email protected]> Reviewers: Jason Gustafson <[email protected]>, Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Tue Feb 28 12:35:04 2017 -0800 Committer: Ewen Cheslack-Postava <[email protected]> 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;
