kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject [50/50] [abbrv] kafka git commit: Merge branch 'trunk' into 0.10.0
Date Fri, 29 Apr 2016 22:06:04 GMT
Merge branch 'trunk' into 0.10.0


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

Branch: refs/heads/0.10.0
Commit: f0d9611866cfdcac120e85d2cd7a82f2f020ed5e
Parents: e97735f d0dedc6
Author: Gwen Shapira <cshapi@gmail.com>
Authored: Fri Apr 29 14:50:50 2016 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Fri Apr 29 14:50:50 2016 -0700

----------------------------------------------------------------------
 bin/kafka-run-class.sh                          |  63 +-
 build.gradle                                    |   4 +-
 checkstyle/checkstyle.xml                       |   7 +
 checkstyle/import-control.xml                   |  19 +
 .../org/apache/kafka/clients/ClientUtils.java   |   4 +-
 .../kafka/clients/CommonClientConfigs.java      |   2 +-
 .../java/org/apache/kafka/clients/Metadata.java |  14 +-
 .../org/apache/kafka/clients/NetworkClient.java |  45 +-
 .../kafka/clients/consumer/KafkaConsumer.java   |  77 ++-
 .../consumer/internals/AbstractCoordinator.java |   4 +-
 .../consumer/internals/ConsumerCoordinator.java |  49 +-
 .../internals/ConsumerNetworkClient.java        |   2 +-
 .../clients/consumer/internals/Fetcher.java     |  20 +-
 .../kafka/clients/producer/KafkaProducer.java   |   4 +-
 .../kafka/clients/producer/RecordMetadata.java  |   6 +
 .../producer/internals/RecordAccumulator.java   |  18 +-
 .../clients/producer/internals/Sender.java      |   2 +-
 .../main/java/org/apache/kafka/common/Node.java |  32 +-
 .../kafka/common/config/AbstractConfig.java     |   3 +-
 .../apache/kafka/common/config/ConfigDef.java   |  44 +-
 .../apache/kafka/common/config/SaslConfigs.java |  15 +-
 .../common/errors/AuthenticationException.java  |  27 +
 .../errors/IllegalSaslStateException.java       |  27 +
 .../UnsupportedSaslMechanismException.java      |  27 +
 .../errors/UnsupportedVersionException.java     |  25 +
 .../apache/kafka/common/metrics/stats/Rate.java |   3 +-
 .../kafka/common/network/ChannelBuilders.java   |  14 +-
 .../apache/kafka/common/network/LoginType.java  |   2 +-
 .../common/network/SaslChannelBuilder.java      |  47 +-
 .../apache/kafka/common/protocol/ApiKeys.java   |   6 +-
 .../apache/kafka/common/protocol/Errors.java    |  11 +-
 .../apache/kafka/common/protocol/Protocol.java  | 100 ++-
 .../kafka/common/protocol/SecurityProtocol.java |   3 +-
 .../kafka/common/protocol/types/ArrayOf.java    |  33 +-
 .../kafka/common/protocol/types/Struct.java     |  36 +-
 .../kafka/common/protocol/types/Type.java       |  43 +-
 .../kafka/common/record/MemoryRecords.java      |   5 +-
 .../kafka/common/requests/AbstractRequest.java  |   6 +-
 .../common/requests/ApiVersionsRequest.java     |  55 ++
 .../common/requests/ApiVersionsResponse.java    | 130 ++++
 .../kafka/common/requests/MetadataRequest.java  |  40 +-
 .../kafka/common/requests/MetadataResponse.java | 101 ++-
 .../kafka/common/requests/ResponseSend.java     |   2 +-
 .../common/requests/SaslHandshakeRequest.java   |  83 +++
 .../common/requests/SaslHandshakeResponse.java  |  85 +++
 .../apache/kafka/common/security/JaasUtils.java |   2 +-
 .../security/auth/AuthCallbackHandler.java      |  46 ++
 .../kafka/common/security/auth/Login.java       |  57 ++
 .../security/authenticator/AbstractLogin.java   | 108 +++
 .../security/authenticator/DefaultLogin.java    |  32 +
 .../security/authenticator/LoginManager.java    | 112 ++++
 .../authenticator/SaslClientAuthenticator.java  | 242 ++++---
 .../SaslClientCallbackHandler.java              |  94 +++
 .../authenticator/SaslServerAuthenticator.java  | 205 +++++-
 .../SaslServerCallbackHandler.java              |  22 +-
 .../common/security/kerberos/KerberosLogin.java | 392 +++++++++++
 .../kafka/common/security/kerberos/Login.java   | 379 -----------
 .../common/security/kerberos/LoginManager.java  | 130 ----
 .../common/security/plain/PlainLoginModule.java |  66 ++
 .../common/security/plain/PlainSaslServer.java  | 170 +++++
 .../security/plain/PlainSaslServerProvider.java |  38 ++
 .../common/serialization/BytesDeserializer.java |  35 +
 .../common/serialization/BytesSerializer.java   |  36 +
 .../kafka/common/serialization/Serdes.java      |  39 +-
 .../org/apache/kafka/common/utils/Bytes.java    | 178 +++++
 .../clients/consumer/KafkaConsumerTest.java     |  13 +-
 .../internals/ConsumerCoordinatorTest.java      |  56 ++
 .../clients/consumer/internals/FetcherTest.java |  11 +-
 .../internals/RecordAccumulatorTest.java        |  14 +-
 .../kafka/common/config/ConfigDefTest.java      |   3 +-
 .../apache/kafka/common/network/CertStores.java |  46 ++
 .../kafka/common/network/NetworkTestUtils.java  |  86 +++
 .../kafka/common/network/NioEchoServer.java     | 145 ++++
 .../common/network/SslTransportLayerTest.java   | 293 ++------
 .../types/ProtocolSerializationTest.java        |  21 +-
 .../kafka/common/record/MemoryRecordsTest.java  |  11 +
 .../common/requests/RequestResponseTest.java    |  46 +-
 .../authenticator/SaslAuthenticatorTest.java    | 553 +++++++++++++++
 .../authenticator/TestDigestLoginModule.java    | 109 +++
 .../security/authenticator/TestJaasConfig.java  |  89 +++
 .../kafka/test/MockConsumerInterceptor.java     |   3 +-
 .../org/apache/kafka/test/TestSslUtils.java     |   3 +
 .../java/org/apache/kafka/test/TestUtils.java   |  58 +-
 config/connect-distributed.properties           |   2 +-
 config/connect-standalone.properties            |   2 +-
 .../kafka/connect/data/ConnectSchema.java       |   2 +-
 .../org/apache/kafka/connect/data/Schema.java   |   3 +-
 .../kafka/connect/cli/ConnectDistributed.java   |  10 +-
 .../kafka/connect/cli/ConnectStandalone.java    |   2 +-
 .../kafka/connect/runtime/AbstractHerder.java   | 149 ++++-
 .../kafka/connect/runtime/AbstractStatus.java   |   1 +
 .../apache/kafka/connect/runtime/Connect.java   |   6 +-
 .../kafka/connect/runtime/ConnectorStatus.java  |  17 +-
 .../apache/kafka/connect/runtime/Herder.java    |  33 +-
 .../kafka/connect/runtime/TargetState.java      |  36 +
 .../kafka/connect/runtime/TaskStatus.java       |  12 +
 .../apache/kafka/connect/runtime/Worker.java    | 112 ++--
 .../kafka/connect/runtime/WorkerConfig.java     |  10 +-
 .../kafka/connect/runtime/WorkerConnector.java  | 206 ++++++
 .../kafka/connect/runtime/WorkerSinkTask.java   |  76 ++-
 .../kafka/connect/runtime/WorkerSourceTask.java |  19 +-
 .../kafka/connect/runtime/WorkerTask.java       | 128 +++-
 .../runtime/distributed/ClusterConfigState.java |  47 +-
 .../runtime/distributed/DistributedHerder.java  | 533 ++++++++-------
 .../distributed/NotAssignedException.java       |  29 +
 .../runtime/distributed/NotLeaderException.java |  21 +-
 .../distributed/RebalanceNeededException.java   |  27 +
 .../distributed/RequestTargetException.java     |  47 ++
 .../runtime/distributed/WorkerCoordinator.java  |  65 +-
 .../runtime/distributed/WorkerGroupMember.java  |  13 +-
 .../kafka/connect/runtime/rest/RestServer.java  |   7 +-
 .../runtime/rest/entities/ConfigKeyInfo.java    |   6 +-
 .../runtime/rest/entities/ConfigValueInfo.java  |  12 +-
 .../rest/resources/ConnectorsResource.java      | 157 +++--
 .../runtime/standalone/StandaloneHerder.java    | 208 +++---
 .../connect/storage/ConfigBackingStore.java     | 127 ++++
 .../storage/KafkaConfigBackingStore.java        | 665 +++++++++++++++++++
 .../connect/storage/KafkaConfigStorage.java     | 594 -----------------
 .../storage/MemoryConfigBackingStore.java       | 166 +++++
 .../connect/storage/StatusBackingStore.java     |   2 +-
 .../kafka/connect/util/ReflectionsUtil.java     |  90 +++
 .../connect/runtime/AbstractHerderTest.java     |  23 +-
 .../connect/runtime/WorkerConnectorTest.java    | 336 ++++++++++
 .../connect/runtime/WorkerSinkTaskTest.java     | 115 +++-
 .../runtime/WorkerSinkTaskThreadedTest.java     |  33 +-
 .../connect/runtime/WorkerSourceTaskTest.java   | 134 +++-
 .../kafka/connect/runtime/WorkerTaskTest.java   |  36 +-
 .../kafka/connect/runtime/WorkerTest.java       |  30 +-
 .../distributed/DistributedHerderTest.java      | 436 ++++++++++--
 .../distributed/WorkerCoordinatorTest.java      |  12 +-
 .../connect/runtime/rest/RestServerTest.java    |  28 +-
 .../resources/ConnectorPluginsResourceTest.java |  64 +-
 .../rest/resources/ConnectorsResourceTest.java  | 151 ++++-
 .../standalone/StandaloneHerderTest.java        | 181 ++++-
 .../storage/KafkaConfigBackingStoreTest.java    | 628 +++++++++++++++++
 .../connect/storage/KafkaConfigStorageTest.java | 534 ---------------
 .../src/main/scala/kafka/admin/AdminUtils.scala |   4 +-
 .../kafka/admin/ReassignPartitionsCommand.scala |  19 +-
 .../main/scala/kafka/admin/TopicCommand.scala   |   4 +-
 core/src/main/scala/kafka/cluster/Broker.scala  |   4 +-
 .../main/scala/kafka/common/ErrorMapping.scala  |   2 +
 core/src/main/scala/kafka/common/Topic.scala    |   5 +-
 .../scala/kafka/consumer/ConsumerConfig.scala   |   3 +-
 .../scala/kafka/consumer/ConsumerIterator.scala |   6 +-
 .../controller/ControllerChannelManager.scala   |  10 +-
 .../kafka/controller/KafkaController.scala      |  19 +-
 .../kafka/coordinator/GroupCoordinator.scala    |  22 +-
 core/src/main/scala/kafka/log/LogConfig.scala   |   5 +-
 .../scala/kafka/message/CompressionCodec.scala  |   8 +-
 .../kafka/message/MessageAndMetadata.scala      |   6 +-
 .../main/scala/kafka/network/SocketServer.scala |   2 +-
 .../scala/kafka/server/DelayedOperation.scala   |  68 +-
 .../src/main/scala/kafka/server/KafkaApis.scala | 140 ++--
 .../main/scala/kafka/server/KafkaConfig.scala   |  38 +-
 .../scala/kafka/server/KafkaHealthcheck.scala   |   2 +-
 .../main/scala/kafka/server/KafkaServer.scala   |   9 +-
 .../main/scala/kafka/server/MetadataCache.scala |  39 +-
 .../kafka/server/ReplicaFetcherThread.scala     |  22 +-
 .../scala/kafka/server/ReplicaManager.scala     |   8 +-
 .../scala/kafka/tools/ConsoleConsumer.scala     |  12 +-
 .../scala/kafka/tools/ConsoleProducer.scala     |   4 +-
 .../scala/kafka/tools/ConsumerPerformance.scala |  14 +-
 .../scala/kafka/tools/EndToEndLatency.scala     |  18 +-
 .../scala/kafka/utils/Log4jController.scala     |   3 +-
 core/src/main/scala/kafka/utils/Os.scala        |   4 +-
 core/src/main/scala/kafka/utils/ZkUtils.scala   |   6 +-
 .../main/scala/kafka/utils/timer/Timer.scala    |  51 +-
 .../scala/kafka/utils/timer/TimerTask.scala     |   2 +-
 .../scala/kafka/utils/timer/TimerTaskList.scala |   7 +-
 .../scala/kafka/utils/timer/TimingWheel.scala   |   2 +-
 .../kafka/api/BaseConsumerTest.scala            |  44 +-
 .../kafka/api/BaseProducerSendTest.scala        |   4 +-
 .../kafka/api/EndToEndAuthorizationTest.scala   |   7 +-
 .../kafka/api/IntegrationTestHarness.scala      |   8 +-
 .../kafka/api/PlaintextConsumerTest.scala       |  33 +-
 .../api/SaslMultiMechanismConsumerTest.scala    |  86 +++
 .../api/SaslPlainPlaintextConsumerTest.scala    |  27 +
 .../SaslPlainSslEndToEndAuthorizationTest.scala |  28 +
 .../scala/integration/kafka/api/SaslSetup.scala |  49 +-
 .../integration/kafka/api/SaslTestHarness.scala |  11 +-
 .../other/kafka/TestPurgatoryPerformance.scala  |   2 +-
 .../admin/ReassignPartitionsClusterTest.scala   | 112 ++++
 .../GroupCoordinatorResponseTest.scala          | 121 +++-
 .../integration/KafkaServerTestHarness.scala    |   4 +-
 .../kafka/integration/RollingBounceTest.scala   |  95 ---
 .../src/test/scala/unit/kafka/log/LogTest.scala |   2 +-
 .../kafka/server/ApiVersionsRequestTest.scala   |  55 ++
 .../unit/kafka/server/ApiVersionsTest.scala     |  51 ++
 .../unit/kafka/server/BaseRequestTest.scala     | 114 ++++
 .../kafka/server/ClientQuotaManagerTest.scala   |   2 +-
 .../kafka/server/DelayedOperationTest.scala     |   2 +-
 .../unit/kafka/server/KafkaConfigTest.scala     |   2 +
 .../unit/kafka/server/MetadataCacheTest.scala   |  46 +-
 .../unit/kafka/server/MetadataRequestTest.scala | 168 +++++
 .../server/SaslApiVersionsRequestTest.scala     |  78 +++
 .../scala/unit/kafka/utils/JaasTestUtils.scala  | 122 ++--
 .../test/scala/unit/kafka/utils/MockTime.scala  |  12 +
 .../test/scala/unit/kafka/utils/TestUtils.scala |  49 +-
 .../unit/kafka/utils/timer/MockTimer.scala      |  57 ++
 .../kafka/utils/timer/TimerTaskListTest.scala   |  12 +-
 .../unit/kafka/utils/timer/TimerTest.scala      |  29 +-
 docs/api.html                                   |   2 +-
 docs/configuration.html                         |   2 +-
 docs/connect.html                               |  60 +-
 docs/implementation.html                        |   4 +-
 docs/migration.html                             |   2 +-
 docs/ops.html                                   |   6 +-
 docs/streams.html                               |   2 +-
 .../examples/KafkaConsumerProducerDemo.java     |   2 +-
 gradle/dependencies.gradle                      |   7 +-
 gradlew                                         |  46 +-
 gradlew.bat                                     |   6 +-
 .../examples/pageview/PageViewTypedDemo.java    |   8 +-
 .../examples/pageview/PageViewUntypedDemo.java  |   6 +-
 .../examples/wordcount/WordCountDemo.java       |   5 +-
 .../wordcount/WordCountProcessorDemo.java       |   3 +-
 .../org/apache/kafka/streams/KafkaStreams.java  |  12 +-
 .../java/org/apache/kafka/streams/KeyValue.java |  17 +
 .../org/apache/kafka/streams/StreamsConfig.java |   6 +-
 .../kafka/streams/kstream/Aggregator.java       |  10 +-
 .../kafka/streams/kstream/ForeachAction.java    |  10 +-
 .../kafka/streams/kstream/HoppingWindows.java   |  95 ---
 .../kafka/streams/kstream/Initializer.java      |   7 +-
 .../kafka/streams/kstream/JoinWindows.java      |  62 +-
 .../kafka/streams/kstream/KGroupedTable.java    |  94 +++
 .../apache/kafka/streams/kstream/KStream.java   | 114 +++-
 .../kafka/streams/kstream/KStreamBuilder.java   |  27 +-
 .../apache/kafka/streams/kstream/KTable.java    | 184 +++--
 .../kafka/streams/kstream/KeyValueMapper.java   |   9 +-
 .../apache/kafka/streams/kstream/Predicate.java |   9 +-
 .../apache/kafka/streams/kstream/Reducer.java   |   9 +-
 .../kafka/streams/kstream/TimeWindows.java      | 133 ++++
 .../kafka/streams/kstream/Transformer.java      |   8 +-
 .../streams/kstream/TransformerSupplier.java    |   7 +-
 .../kafka/streams/kstream/TumblingWindows.java  |  74 ---
 .../kafka/streams/kstream/UnlimitedWindows.java |  40 +-
 .../kafka/streams/kstream/ValueJoiner.java      |   9 +-
 .../kafka/streams/kstream/ValueMapper.java      |   8 +-
 .../kafka/streams/kstream/ValueTransformer.java |   8 +-
 .../kstream/ValueTransformerSupplier.java       |   7 +-
 .../apache/kafka/streams/kstream/Window.java    |  32 +-
 .../apache/kafka/streams/kstream/Windowed.java  |  30 +-
 .../apache/kafka/streams/kstream/Windows.java   |  43 +-
 .../kstream/internals/AbstractStream.java       |   3 +
 .../kstream/internals/ChangedDeserializer.java  |  10 +-
 .../kstream/internals/ChangedSerializer.java    |  14 +-
 .../kstream/internals/HoppingWindow.java        |  37 --
 .../kstream/internals/KGroupedTableImpl.java    | 153 +++++
 .../kstream/internals/KStreamAggregate.java     |   3 +
 .../streams/kstream/internals/KStreamImpl.java  |  20 +-
 .../kstream/internals/KStreamJoinWindow.java    |   3 +
 .../kstream/internals/KStreamKStreamJoin.java   |   3 +
 .../kstream/internals/KStreamReduce.java        |   3 +
 .../internals/KStreamWindowAggregate.java       |   2 +-
 .../kstream/internals/KStreamWindowReduce.java  |   2 +-
 .../kstream/internals/KTableAggregate.java      |   3 +
 .../streams/kstream/internals/KTableImpl.java   | 170 +----
 .../kstream/internals/KTableKTableJoin.java     |   3 +
 .../kstream/internals/KTableKTableLeftJoin.java |   3 +
 .../internals/KTableKTableOuterJoin.java        |   3 +
 .../internals/KTableKTableRightJoin.java        |   3 +
 .../streams/kstream/internals/KTableReduce.java |   3 +
 .../kstream/internals/KTableRepartitionMap.java |   6 +
 .../streams/kstream/internals/TimeWindow.java   |  33 +
 .../kstream/internals/TumblingWindow.java       |  38 --
 .../kstream/internals/UnlimitedWindow.java      |   8 +-
 .../kstream/internals/WindowedSerializer.java   |   4 +-
 .../internals/WindowedStreamPartitioner.java    |   6 +-
 .../ConsumerRecordTimestampExtractor.java       |   3 +-
 .../processor/DefaultPartitionGrouper.java      |   3 +
 .../kafka/streams/processor/Processor.java      |   9 +-
 .../streams/processor/ProcessorSupplier.java    |   5 +
 .../kafka/streams/processor/StateStore.java     |   4 +-
 .../streams/processor/StateStoreSupplier.java   |  10 +
 .../streams/processor/StreamPartitioner.java    |  20 +-
 .../apache/kafka/streams/processor/TaskId.java  |  13 +-
 .../streams/processor/TimestampExtractor.java   |   8 +-
 .../streams/processor/TopologyBuilder.java      |  69 +-
 .../processor/WallclockTimestampExtractor.java  |   9 +-
 .../processor/internals/AbstractTask.java       |   6 +
 .../internals/InternalTopicManager.java         |  35 +-
 .../internals/MinTimestampTracker.java          |   3 +
 .../processor/internals/PartitionGroup.java     |   3 +
 .../internals/ProcessorContextImpl.java         |  18 +
 .../internals/ProcessorStateManager.java        |  18 +
 .../streams/processor/internals/QuickUnion.java |   3 +
 .../streams/processor/internals/SinkNode.java   |  17 +
 .../streams/processor/internals/SourceNode.java |  18 +-
 .../processor/internals/StandbyContextImpl.java |  33 +
 .../internals/StreamPartitionAssignor.java      | 124 ++--
 .../streams/processor/internals/StreamTask.java |   7 +
 .../processor/internals/StreamThread.java       |   8 +-
 .../internals/assignment/AssignmentInfo.java    |   7 +
 .../internals/assignment/SubscriptionInfo.java  |   6 +
 .../apache/kafka/streams/state/StateSerdes.java |  80 ++-
 .../org/apache/kafka/streams/state/Stores.java  |   4 +
 .../apache/kafka/streams/state/WindowStore.java |   4 +-
 .../kafka/streams/state/WindowStoreUtils.java   |  63 --
 .../InMemoryKeyValueStoreSupplier.java          |  13 +-
 .../streams/state/internals/MemoryLRUCache.java |  19 +
 .../state/internals/MeteredKeyValueStore.java   |   8 +-
 .../state/internals/OffsetCheckpoint.java       |  23 +
 .../state/internals/RawStoreChangeLogger.java   |  56 --
 .../streams/state/internals/RocksDBStore.java   |  81 +--
 .../state/internals/RocksDBWindowStore.java     |  52 +-
 .../state/internals/StoreChangeLogger.java      |  10 +
 .../state/internals/WindowStoreUtils.java       |  65 ++
 .../InternalTopicIntegrationTest.java           | 169 +++++
 .../utils/EmbeddedSingleNodeKafkaCluster.java   | 128 ++++
 .../integration/utils/IntegrationTestUtils.java | 157 +++++
 .../integration/utils/KafkaEmbedded.java        | 189 ++++++
 .../streams/kstream/KStreamBuilderTest.java     |  13 +-
 .../kafka/streams/kstream/TimeWindowsTest.java  | 123 ++++
 .../streams/kstream/UnlimitedWindowsTest.java   |  80 +++
 .../internals/KGroupedTableImplTest.java        |  79 +++
 .../kstream/internals/KStreamBranchTest.java    |  13 +-
 .../kstream/internals/KStreamFilterTest.java    |  15 +-
 .../kstream/internals/KStreamFlatMapTest.java   |  13 +-
 .../internals/KStreamFlatMapValuesTest.java     |  16 +-
 .../kstream/internals/KStreamForeachTest.java   |  16 +-
 .../kstream/internals/KStreamImplTest.java      |   7 +
 .../internals/KStreamKStreamJoinTest.java       | 651 +++++++++---------
 .../internals/KStreamKStreamLeftJoinTest.java   | 341 +++++-----
 .../internals/KStreamKTableLeftJoinTest.java    | 153 +++--
 .../kstream/internals/KStreamMapTest.java       |  13 +-
 .../kstream/internals/KStreamMapValuesTest.java |  13 +-
 .../kstream/internals/KStreamSelectKeyTest.java |  94 +++
 .../kstream/internals/KStreamTransformTest.java |  13 +-
 .../internals/KStreamTransformValuesTest.java   |  13 +-
 .../internals/KStreamWindowAggregateTest.java   |  48 +-
 .../kstream/internals/KTableAggregateTest.java  | 119 ++--
 .../kstream/internals/KTableFilterTest.java     | 327 +++++----
 .../kstream/internals/KTableForeachTest.java    |  16 +-
 .../kstream/internals/KTableImplTest.java       | 444 +++++++------
 .../kstream/internals/KTableKTableJoinTest.java | 394 ++++++-----
 .../internals/KTableKTableLeftJoinTest.java     | 397 ++++++-----
 .../internals/KTableKTableOuterJoinTest.java    | 426 ++++++------
 .../kstream/internals/KTableMapKeysTest.java    |  99 +++
 .../kstream/internals/KTableMapValuesTest.java  | 381 ++++++-----
 .../kstream/internals/KTableSourceTest.java     | 172 ++---
 .../internals/KeyValuePrinterProcessorTest.java |  15 +-
 .../WindowedStreamPartitionerTest.java          |   4 +-
 .../streams/kstream/internals/WindowsTest.java  |  70 --
 .../kafka/streams/perf/SimpleBenchmark.java     |   1 +
 .../internals/ProcessorStateManagerTest.java    |   5 +-
 .../internals/StreamPartitionAssignorTest.java  |   2 +-
 .../streams/smoketest/SmokeTestClient.java      |  23 +-
 .../streams/smoketest/SmokeTestDriver.java      |   2 +-
 .../kafka/streams/smoketest/SmokeTestUtil.java  |   2 +-
 .../streams/state/KeyValueStoreTestDriver.java  |  15 +-
 .../internals/AbstractKeyValueStoreTest.java    |   2 -
 .../state/internals/RocksDBWindowStoreTest.java |   1 -
 .../state/internals/StoreChangeLoggerTest.java  |  41 --
 .../apache/kafka/test/KStreamTestDriver.java    |  54 +-
 .../org/apache/kafka/test/MockAggregator.java   |  43 ++
 .../org/apache/kafka/test/MockInitializer.java  |  33 +
 .../apache/kafka/test/MockKeyValueMapper.java   |  36 +
 .../java/org/apache/kafka/test/MockReducer.java |  43 ++
 .../org/apache/kafka/test/MockValueJoiner.java  |  33 +
 .../apache/kafka/test/NoOpKeyValueMapper.java   |  29 -
 .../kafkatest/benchmarks/core/benchmark_test.py | 121 ++--
 .../sanity_checks/test_console_consumer.py      |   5 +-
 .../sanity_checks/test_performance_services.py  |  88 +++
 tests/kafkatest/services/console_consumer.py    |  15 +-
 tests/kafkatest/services/kafka/kafka.py         |  14 +-
 .../services/kafka/templates/kafka.properties   |   5 +-
 .../kafkatest/services/performance/__init__.py  |   4 +-
 .../performance/consumer_performance.py         |  45 +-
 .../services/performance/end_to_end_latency.py  |  82 ++-
 .../services/performance/performance.py         |  23 +
 .../performance/producer_performance.py         | 159 +++--
 .../services/replica_verification_tool.py       |  81 +++
 tests/kafkatest/services/security/minikdc.py    |   5 +-
 .../services/security/security_config.py        |  27 +-
 .../security/templates/gssapi_jaas.conf         |  86 ---
 .../services/security/templates/jaas.conf       |  95 +++
 tests/kafkatest/services/streams.py             |  10 +-
 .../services/templates/tools_log4j.properties   |   2 +-
 tests/kafkatest/services/verifiable_producer.py |  14 +-
 tests/kafkatest/tests/core/replication_test.py  |   7 +-
 .../tests/tools/replica_verification_test.py    |  88 +++
 .../apache/kafka/tools/ProducerPerformance.java |   7 +-
 .../apache/kafka/tools/VerifiableProducer.java  |   8 +
 vagrant/base.sh                                 |   2 +
 384 files changed, 16183 insertions(+), 6765 deletions(-)
----------------------------------------------------------------------



Mime
View raw message