/
[Apache-SVN]
Revision 1235492
Jump to revision:
Author:
nehanarkhede
Date:
Tue Jan 24 20:54:11 2012 UTC
(12 years, 9 months ago)
Changed paths:
90
Log Message:
KAFKA-238 getTopicMetadata API; patched by nehanarkhede; reviewed by junrao
Changed paths
Path
Details
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/admin/CreateTopicCommand.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/ListTopicCommand.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/PartitionMetaData.scala
deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/MultiFetchRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerRequest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestKeys.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetadata.scala
added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetadataRequest.scala
added
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/Cluster.scala
modified
,
text changed
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/common/KafkaZookeperClient.scala
added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/storage/OracleOffsetStorage.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/Implicits.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/message/MessageSet.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/Producer.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/message/ByteBufferBackedInputStream.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/CompressionUtils.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/FileMessageSet.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/Message.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/RequestChannel.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/network/SocketServerStats.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConfigBrokerPartitionInfo.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConsoleProducer.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducerConfig.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ZKBrokerPartitionInfo.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducer.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/KafkaConfig.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/KafkaRequestHandlers.scala
deleted
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/MultiMessageSetSend.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/JmxTool.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ProducerShell.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ReplayLogProducer.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/KafkaScheduler.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Range.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkUtils.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/resources/log4j.properties
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestKafkaAppender.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestLogPerformance.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/admin/AdminTest.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/integration/AutoOffsetResetTest.scala
modified
,
text changed
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/KafkaServerTestHarness.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/LogCorruptionTest.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
added
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/javaapi/integration/PrimitiveApiTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/message/BaseMessageSetTestCases.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/producer/ProducerTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/producer/SyncProducerTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogManagerTest.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/log/LogTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/FileMessageSetTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/MessageTest.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/ServerShutdownTest.scala
modified
,
text changed
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
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/ZKLoadBalanceTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala
modified
,
text changed
incubator/kafka/branches/0.8/project/build.properties
modified
,
text changed
infrastructure at apache.org
ViewVC Help
Powered by
ViewVC 1.1.26