 incubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/AdminUtils.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/LeaderAndISRRequest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/StopReplicaRequest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Broker.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Partition.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/BrokerNotExistException.scala
|
deleted
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ErrorMapping.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/TopicCount.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/Log.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/LogManager.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/SocketServer.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherManager.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaController.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaRequestHandler.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServer.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaZooKeeper.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherManager.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/RequestPurgatory.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommand.scala
(Copied from incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommand.scala, r1367618)
|
added
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommandHandler.scala
(Copied from incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommandHandler.scala, r1367618)
|
added
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ExportZkOffsets.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkQueue.scala
(Copied from incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkQueue.scala, r1367618)
|
added
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkUtils.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerBasicTest.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerToBrokerRequestTest.scala
(Copied from incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerToBrokerRequestTest.scala, r1367618)
|
added
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/BackwardsCompatibilityTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/FetcherTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/StateChangeTest.scala
(Copied from incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/StateChangeTest.scala, r1367618)
|
added
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/ZKEphemeralTest.scala
|
modified
, text changed
|
