Commits

Branch selector

 master

User selector

nehanarkhede

Datepicker

All time

Commit History

Commits on Aug 1, 2011

• Moving java files to src/main/java

  nehanarkhede

  committed
  be7bc44

Commits on Jul 30, 2011

• Merged the compression feature and updated version to 0.7

  nehanarkhede

  committed
  709afe4

• Merge branch 'master' of github.com:kafka-dev/kafka

  nehanarkhede

  committed
  6e489aa

• Deleting the deepIterate flag from ByteBufferMessageSet. No shallow iteration is possible

  nehanarkhede

  committed
  2934228

Commits on Jul 29, 2011

• Replaced references of MessageOffset to use MessageAndOffset

  nehanarkhede

  committed
  08276e1

• Renamed MessageOffset to MessageAndOffset. Cleaned up code. Changed method names to camel case in Message.scala. Moved compression config to ProducerConfig

  nehanarkhede

  committed
  4b4c50d

Commits on Jul 22, 2011

• More code cleanup. Changed the visibility of variables in ByteBufferMessageSet to private with accessor methods. Deleted unused code

  nehanarkhede

  committed
  4c49c4e

• Added backwards compatibility unit test to verify if older versions of magic byte can be understood by newer versions

  nehanarkhede

  committed
  2715ec7

• Handling IO Exceptions while compressing (producer side) or decompressing (consumer side) and rethrowing to the client

  nehanarkhede

  committed
  2495618

• Code cleanup. Deleted a constructor from ByteBufferMessageSet and an overloaded method from MessageSet

  nehanarkhede

  committed
  e039b8e

• Added a system test for producer with compression enabled. Corrected the logic for enforcing compressed.topics. Changed message.isValid to check the magic byte and throw UnknownMagicByteException i…

  Show description for fab1263
  nehanarkhede

  committed
  fab1263

Commits on Jul 21, 2011

• Corrected ByteBufferMessageSet to take in an initial offset and use that in the iterator to return the correct offset to consume the next message

  nehanarkhede

  committed
  18009f3

Commits on Jul 7, 2011

• Code cleanup

  nehanarkhede

  committed
  8db5014

• Adding .project to .gitignore

  nehanarkhede

  committed
  6b501c0

• Adding .settings and .idea to .gitignore

  nehanarkhede

  committed
  ae3cf6d

• Pulling from latest origin/master

  nehanarkhede

  committed
  13e067a

• Updating consumed and fetched offset at the FetchedDataChunk level. Both unit and system tests pass

  nehanarkhede

  committed
  d5105fb

Commits on Jul 5, 2011

• improving documentation in config/server.properties

  nehanarkhede

  committed
  2e4b477

Commits on Jun 29, 2011

• Merging latest contents from kafka-dev/master

  nehanarkhede

  committed
  44f1fbd

• Upgrading producer send thread shutdown message to INFO. Adding a DEBUG log message for the last batch handled by the producer send thread before shutdown

  nehanarkhede

  committed
  3de39bd

• Fixed a bug in ConsumerIterator for updating consumed offset. Added a replay log script that reads from a topic and sends it to another topic with compression turned ON/OFF

  nehanarkhede

  committed
  a73dbd9

Commits on Jun 21, 2011

• Pulled latest changes from kafka-dev/master

  nehanarkhede

  committed
  c9a91ac

Commits on Jun 18, 2011

• Deleting the throughput thread from the AsyncProducerStats

  nehanarkhede

  committed
  3ac5935

Commits on Jun 17, 2011

• Merge branch 'master' of github.com:kafka-dev/kafka

  nehanarkhede

  committed
  cfe06af

• Upgrade the connection established in SyncProducer to INFO

  nehanarkhede

  committed
  4592215

Commits on Jun 1, 2011

• Adding a setup file for hadoop consumer to set write permissions on the required hdfs directories

  nehanarkhede

  committed
  cc5f603

• Fixed producer perf script to calculate throughput correctly. Also fixed the classpaths and configs for the hadoop consumer

  nehanarkhede

  committed
  ead90af

Commits on May 23, 2011

• KAFKA-66: cleanup

  nehanarkhede

  committed
  d784087

Commits on May 19, 2011

• Adding more unit tests for producer

  nehanarkhede

  committed
  2aebeac

Commits on May 18, 2011

• Bootstrapping an empty topic for zookeeper producer

  nehanarkhede

  committed
  9014610

Commits on May 17, 2011

• Deleting contrib. Refer to KAFKA-63

  nehanarkhede

  committed
  aa176ff

• Merge branch 'master' of github.com:kafka-dev/kafka

  nehanarkhede

  committed
  213b253

• KAFKA-61: Improve EventHandler in AsyncProducer

  nehanarkhede

  committed
  9064047

• Passing in Encoder through the handle() API for EventHandler

  nehanarkhede

  committed
  2b4cd12

• Removing sync producer from the constructor of the DefaultEventHandler

  nehanarkhede

  committed
  edc00b7

Pagination

PreviousNext