/[Apache-SVN]
ViewVC logotype

Revision 1154719

Jump to revision: Previous Next
Author: junrao
Date: Sun Aug 7 16:29:55 2011 UTC (13 years, 2 months ago)
Changed paths: 11
Log Message: 
commit offset before consumer shutdown KAFKA-84; rename util.StringSerializer to ZKStringSerializer to avoid confusion with producer.StringSerializer

Changed paths

Path Details
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ZKBrokerPartitionInfo.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaZooKeeper.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/ReplayLogProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/ZkUtils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/other/kafka/DeleteZKPath.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/unit/kafka/utils/TestUtils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/unit/kafka/zk/ZKEphemeralTest.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26