/[Apache-SVN]
ViewVC logotype

Revision 1415021

Jump to revision: Previous Next
Author: nehanarkhede
Date: Thu Nov 29 01:31:18 2012 UTC (11 years, 10 months ago)
Changed paths: 63
Log Message: 
KAFKA-622 Create mbeans per client; patched by Swapnil; reviewed by Neha Narkhede

Changed paths

Path Details
Directorykafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/client/ClientUtils.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/common/InvalidClientIdException.scala added
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerIterator.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerTopicStat.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerTopicStats.scala added
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/KafkaStream.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/SimpleConsumer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/controller/KafkaController.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionStateMachine.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/controller/ReplicaStateMachine.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/log/Log.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/ConsoleProducer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/DefaultPartitioner.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/Producer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerPool.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducerConfig.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/serializer/Decoder.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/serializer/Encoder.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherThread.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/server/KafkaRequestHandler.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/GetOffsetShell.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/MirrorMaker.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/ReplayLogProducer.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/tools/UpdateOffsetsInZK.scala modified , text changed
Directorykafka/branches/0.8/core/src/main/scala/kafka/utils/ClientIdAndTopic.scala added
Directorykafka/branches/0.8/core/src/main/scala/kafka/utils/Topic.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/other/kafka/TestKafkaAppender.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/integration/FetcherTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala modified , text changed
Directorykafka/branches/0.8/core/src/test/scala/unit/kafka/utils/ClientIdTest.scala added
Directorykafka/branches/0.8/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java modified , text changed
Directorykafka/branches/0.8/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26