Browse Source

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
pull/2594/merge
Matthias J. Sax 8 years ago committed by Ewen Cheslack-Postava
parent
commit
d0e436c471
  1. 4
      checkstyle/checkstyle.xml
  2. 16
      checkstyle/java.header
  3. 26
      clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
  4. 26
      clients/src/main/java/org/apache/kafka/clients/ClientResponse.java
  5. 22
      clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
  6. 26
      clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
  7. 23
      clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
  8. 26
      clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
  9. 26
      clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java
  10. 26
      clients/src/main/java/org/apache/kafka/clients/KafkaClient.java
  11. 23
      clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java
  12. 22
      clients/src/main/java/org/apache/kafka/clients/Metadata.java
  13. 23
      clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java
  14. 22
      clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
  15. 22
      clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java
  16. 26
      clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java
  17. 6
      clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java
  18. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java
  19. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
  20. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
  21. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
  22. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
  23. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
  24. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java
  25. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
  26. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java
  27. 27
      clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java
  28. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java
  29. 6
      clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java
  30. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
  31. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java
  32. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java
  33. 12
      clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java
  34. 6
      clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java
  35. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java
  36. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
  37. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java
  38. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
  39. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java
  40. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java
  41. 6
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java
  42. 23
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
  43. 26
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java
  44. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java
  45. 27
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java
  46. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java
  47. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java
  48. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java
  49. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java
  50. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/StaleMetadataException.java
  51. 22
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
  52. 6
      clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java
  53. 6
      clients/src/main/java/org/apache/kafka/clients/producer/Callback.java
  54. 22
      clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
  55. 6
      clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java
  56. 7
      clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java
  57. 6
      clients/src/main/java/org/apache/kafka/clients/producer/Producer.java
  58. 22
      clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
  59. 6
      clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java
  60. 26
      clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java
  61. 6
      clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java
  62. 6
      clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java
  63. 6
      clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java
  64. 23
      clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java
  65. 26
      clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java
  66. 6
      clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java
  67. 6
      clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java
  68. 26
      clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
  69. 26
      clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java
  70. 26
      clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
  71. 26
      clients/src/main/java/org/apache/kafka/common/Cluster.java
  72. 7
      clients/src/main/java/org/apache/kafka/common/ClusterResource.java
  73. 23
      clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java
  74. 6
      clients/src/main/java/org/apache/kafka/common/Configurable.java
  75. 6
      clients/src/main/java/org/apache/kafka/common/KafkaException.java
  76. 6
      clients/src/main/java/org/apache/kafka/common/Metric.java
  77. 24
      clients/src/main/java/org/apache/kafka/common/MetricName.java
  78. 22
      clients/src/main/java/org/apache/kafka/common/Node.java
  79. 26
      clients/src/main/java/org/apache/kafka/common/PartitionInfo.java
  80. 6
      clients/src/main/java/org/apache/kafka/common/TopicPartition.java
  81. 22
      clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java
  82. 9
      clients/src/main/java/org/apache/kafka/common/cache/Cache.java
  83. 9
      clients/src/main/java/org/apache/kafka/common/cache/LRUCache.java
  84. 9
      clients/src/main/java/org/apache/kafka/common/cache/SynchronizedCache.java
  85. 22
      clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
  86. 22
      clients/src/main/java/org/apache/kafka/common/config/Config.java
  87. 22
      clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
  88. 6
      clients/src/main/java/org/apache/kafka/common/config/ConfigException.java
  89. 15
      clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java
  90. 23
      clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java
  91. 23
      clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java
  92. 9
      clients/src/main/java/org/apache/kafka/common/config/types/Password.java
  93. 6
      clients/src/main/java/org/apache/kafka/common/errors/ApiException.java
  94. 22
      clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java
  95. 22
      clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java
  96. 7
      clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java
  97. 22
      clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java
  98. 7
      clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java
  99. 22
      clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java
  100. 22
      clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java
  101. Some files were not shown because too many files have changed in this diff Show More

4
checkstyle/checkstyle.xml

@ -24,8 +24,8 @@
<module name="FileTabCharacter"/> <module name="FileTabCharacter"/>
<!-- header --> <!-- header -->
<module name="RegexpHeader"> <module name="Header">
<property name="header" value="/\*\*\nLicensed to the Apache.*"/> <property name="headerFile" value="checkstyle/java.header" />
</module> </module>
<module name="TreeWalker"> <module name="TreeWalker">

16
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.
*/

26
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

26
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

22
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;

26
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

23
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;
import org.apache.kafka.common.protocol.SecurityProtocol; import org.apache.kafka.common.protocol.SecurityProtocol;

26
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

26
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 * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

26
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

23
clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;
import org.apache.kafka.common.Node; import org.apache.kafka.common.Node;

22
clients/src/main/java/org/apache/kafka/clients/Metadata.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;

23
clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;
import org.apache.kafka.common.Node; import org.apache.kafka.common.Node;

22
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;

22
clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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; package org.apache.kafka.clients;

26
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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; package org.apache.kafka.clients;

6
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

26
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer; package org.apache.kafka.clients.consumer;

26
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/InvalidOffsetException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

27
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer; package org.apache.kafka.clients.consumer;
import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.TopicPartition;

22
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndMetadata.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

6
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetAndTimestamp.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

26
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer; package org.apache.kafka.clients.consumer;

22
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer; package org.apache.kafka.clients.consumer;

12
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java

@ -1,13 +1,13 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * the License. You may obtain a copy of the License at
* <p/> *
* http://www.apache.org/licenses/LICENSE-2.0 * http://www.apache.org/licenses/LICENSE-2.0
* <p/> *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

6
clients/src/main/java/org/apache/kafka/clients/consumer/RetriableCommitFailedException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

26
clients/src/main/java/org/apache/kafka/clients/consumer/RoundRobinAssignor.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * The ASF licenses this file to You under the Apache License, Version 2.0
* <p/> * (the "License"); you may not use this file except in compliance with
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* <p/> *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer; package org.apache.kafka.clients.consumer;

26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * The ASF licenses this file to You under the Apache License, Version 2.0
* <p/> * (the "License"); you may not use this file except in compliance with
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* <p/> *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * The ASF licenses this file to You under the Apache License, Version 2.0
* <p/> * (the "License"); you may not use this file except in compliance with
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* <p/> *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

6
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

23
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;
import org.apache.kafka.clients.ClientResponse; import org.apache.kafka.clients.ClientResponse;

26
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

27
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;
import org.apache.kafka.clients.consumer.ConsumerRebalanceListener; import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PartitionAssignor.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFutureListener.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StaleMetadataException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

22
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.consumer.internals; package org.apache.kafka.clients.consumer.internals;

6
clients/src/main/java/org/apache/kafka/clients/producer/BufferExhaustedException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/clients/producer/Callback.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.producer; package org.apache.kafka.clients.producer;

6
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

7
clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.kafka.clients.producer; package org.apache.kafka.clients.producer;
import org.apache.kafka.common.Configurable; import org.apache.kafka.common.Configurable;

6
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.producer; package org.apache.kafka.clients.producer;

6
clients/src/main/java/org/apache/kafka/clients/producer/ProducerInterceptor.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

26
clients/src/main/java/org/apache/kafka/clients/producer/ProducerRecord.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.producer; package org.apache.kafka.clients.producer;

6
clients/src/main/java/org/apache/kafka/clients/producer/RecordMetadata.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

23
clients/src/main/java/org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.producer.internals; package org.apache.kafka.clients.producer.internals;
import org.apache.kafka.clients.producer.Callback; import org.apache.kafka.clients.producer.Callback;

26
clients/src/main/java/org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.producer.internals; package org.apache.kafka.clients.producer.internals;

6
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

26
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.producer.internals; package org.apache.kafka.clients.producer.internals;

26
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.producer.internals; package org.apache.kafka.clients.producer.internals;

26
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.producer.internals; package org.apache.kafka.clients.producer.internals;

26
clients/src/main/java/org/apache/kafka/common/Cluster.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.common; package org.apache.kafka.common;

7
clients/src/main/java/org/apache/kafka/common/ClusterResource.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.kafka.common; package org.apache.kafka.common;

23
clients/src/main/java/org/apache/kafka/common/ClusterResourceListener.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common; package org.apache.kafka.common;
/** /**

6
clients/src/main/java/org/apache/kafka/common/Configurable.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/common/KafkaException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

6
clients/src/main/java/org/apache/kafka/common/Metric.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

24
clients/src/main/java/org/apache/kafka/common/MetricName.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common; package org.apache.kafka.common;
@ -205,4 +209,4 @@ public final class MetricName {
return "MetricName [name=" + name + ", group=" + group + ", description=" return "MetricName [name=" + name + ", group=" + group + ", description="
+ description + ", tags=" + tags + "]"; + description + ", tags=" + tags + "]";
} }
} }

22
clients/src/main/java/org/apache/kafka/common/Node.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common; package org.apache.kafka.common;

26
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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
* http://www.apache.org/licenses/LICENSE-2.0 * the License. You may obtain a copy of the License at
* *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * http://www.apache.org/licenses/LICENSE-2.0
* 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.common; package org.apache.kafka.common;

6
clients/src/main/java/org/apache/kafka/common/TopicPartition.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/common/annotation/InterfaceStability.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.annotation; package org.apache.kafka.common.annotation;

9
clients/src/main/java/org/apache/kafka/common/cache/Cache.java vendored

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -13,8 +13,7 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
**/ */
package org.apache.kafka.common.cache; package org.apache.kafka.common.cache;
/** /**

9
clients/src/main/java/org/apache/kafka/common/cache/LRUCache.java vendored

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -13,8 +13,7 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
**/ */
package org.apache.kafka.common.cache; package org.apache.kafka.common.cache;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;

9
clients/src/main/java/org/apache/kafka/common/cache/SynchronizedCache.java vendored

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -13,8 +13,7 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
**/ */
package org.apache.kafka.common.cache; package org.apache.kafka.common.cache;
/** /**

22
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.config; package org.apache.kafka.common.config;

22
clients/src/main/java/org/apache/kafka/common/config/Config.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.config; package org.apache.kafka.common.config;

22
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.config; package org.apache.kafka.common.config;

6
clients/src/main/java/org/apache/kafka/common/config/ConfigException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

15
clients/src/main/java/org/apache/kafka/common/config/ConfigValue.java

@ -1,20 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * the License. You may obtain a copy of the License at
* <p/> *
* http://www.apache.org/licenses/LICENSE-2.0 * http://www.apache.org/licenses/LICENSE-2.0
* <p/> *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
**/ */
package org.apache.kafka.common.config; package org.apache.kafka.common.config;
import java.util.ArrayList; import java.util.ArrayList;

23
clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.config; package org.apache.kafka.common.config;
import java.util.Collections; import java.util.Collections;

23
clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java

@ -1,16 +1,19 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.config; package org.apache.kafka.common.config;
import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.KeyManagerFactory;

9
clients/src/main/java/org/apache/kafka/common/config/types/Password.java

@ -1,12 +1,12 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.kafka.common.config.types; package org.apache.kafka.common.config.types;
/** /**

6
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *

22
clients/src/main/java/org/apache/kafka/common/errors/AuthenticationException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.errors; package org.apache.kafka.common.errors;

22
clients/src/main/java/org/apache/kafka/common/errors/AuthorizationException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.errors; package org.apache.kafka.common.errors;

7
clients/src/main/java/org/apache/kafka/common/errors/BrokerNotAvailableException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.kafka.common.errors; package org.apache.kafka.common.errors;
public class BrokerNotAvailableException extends ApiException { public class BrokerNotAvailableException extends ApiException {

22
clients/src/main/java/org/apache/kafka/common/errors/ClusterAuthorizationException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.errors; package org.apache.kafka.common.errors;

7
clients/src/main/java/org/apache/kafka/common/errors/ControllerMovedException.java

@ -1,10 +1,10 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0 * 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 not use this file except in compliance with
* the License. You may obtain a copy of the License at * 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
* *
@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.apache.kafka.common.errors; package org.apache.kafka.common.errors;
public class ControllerMovedException extends ApiException { public class ControllerMovedException extends ApiException {

22
clients/src/main/java/org/apache/kafka/common/errors/CorruptRecordException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.errors; package org.apache.kafka.common.errors;

22
clients/src/main/java/org/apache/kafka/common/errors/DisconnectException.java

@ -1,14 +1,18 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE * Licensed to the Apache Software Foundation (ASF) under one or more
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file * contributor license agreements. See the NOTICE file distributed with
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the * this work for additional information regarding copyright ownership.
* License. You may obtain a copy of the License at * 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 * Unless required by applicable law or agreed to in writing, software
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * distributed under the License is distributed on an "AS IS" BASIS,
* specific language governing permissions and limitations under the License. * 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.common.errors; package org.apache.kafka.common.errors;

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save