/[Apache-SVN]
ViewVC logotype

Revision 1156232

Jump to revision: Previous Next
Author: hsaputra
Date: Wed Aug 10 15:33:21 2011 UTC (13 years, 2 months ago)
Changed paths: 188 (showing only 100; show all)
Log Message: 
KAFKA-93 | Change and add ASF source header to follow standard ASF source header (http://www.apache.org/legal/src-headers.html).

Changed paths

Path Details
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLInputFormat.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLJob.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLKey.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRecordReader.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRequest.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLUtils.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/Props.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/UndefinedPropertyException.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/SimpleKafkaETLJob.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/SimpleKafkaETLMapper.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/examples/TextPublisher.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaRecordWriter.java modified , text changed
Directoryincubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/pig/AvroKafkaStorage.java modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/Kafka.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/FetchRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/MultiFetchRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/MultiFetchResponse.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/MultiProducerRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/OffsetRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/ProducerRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/RequestKeys.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/cluster/Broker.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/cluster/Cluster.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/cluster/Partition.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/ErrorMapping.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/InvalidConfigException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/InvalidPartitionException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/OffsetOutOfRangeException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/UnavailableProducerException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/UnknownCodecException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/UnknownException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/UnknownMagicByteException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerIterator.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetchedDataChunk.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/Fetcher.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaMessageStream.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/TopicCount.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/consumer/storage/MemoryOffsetStorage.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/storage/OffsetStorage.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/storage/OracleOffsetStorage.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/Implicits.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/MultiFetchResponse.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/ProducerRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/message/MessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/Producer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/ProducerData.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/SyncProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/async/CallbackHandler.java modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/async/EventHandler.java modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/log/Log.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/log/LogManager.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/log/LogStats.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/log/SegmentList.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/CompressionCodec.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/CompressionUtils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/FileMessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/InvalidMessageException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/Message.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/MessageAndOffset.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/MessageLengthException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/MessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/BoundedByteBufferSend.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/ByteBufferSend.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/ConnectionConfig.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/Handler.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/InvalidRequestException.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/Request.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/SocketServer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/SocketServerStats.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/Transmission.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ConfigBrokerPartitionInfo.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/DefaultPartitioner.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/Partitioner.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/Producer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ProducerConfig.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ProducerData.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ProducerPool.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducerConfig.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/producer/async/AsyncProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala modified , text changed
[...]
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26