Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 61FFE19387 for ; Fri, 29 Apr 2016 22:05:18 +0000 (UTC) Received: (qmail 54772 invoked by uid 500); 29 Apr 2016 22:05:17 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 54714 invoked by uid 500); 29 Apr 2016 22:05:17 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 54150 invoked by uid 99); 29 Apr 2016 22:05:17 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Apr 2016 22:05:17 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 9E44BE0211; Fri, 29 Apr 2016 22:05:17 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: gwenshap@apache.org To: commits@kafka.apache.org Date: Fri, 29 Apr 2016 22:06:04 -0000 Message-Id: <5df88ac8051645c3946435ee98337ef7@git.apache.org> In-Reply-To: <8bdcb5eccf844631b7da71678b178883@git.apache.org> References: <8bdcb5eccf844631b7da71678b178883@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [50/50] [abbrv] kafka git commit: Merge branch 'trunk' into 0.10.0 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 Authored: Fri Apr 29 14:50:50 2016 -0700 Committer: Gwen Shapira 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(-) ----------------------------------------------------------------------