kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [26/37] git commit: Merge branch '0.8' of https://git-wip-us.apache.org/repos/asf/kafka into 0.8
Date Mon, 04 Mar 2013 04:22:00 GMT
Merge branch '0.8' of https://git-wip-us.apache.org/repos/asf/kafka into 0.8


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ccfdabc0
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ccfdabc0
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ccfdabc0

Branch: refs/heads/trunk
Commit: ccfdabc045175491ebe95ee50d18646caeafd916
Parents: 9115977 4d8fb1e
Author: Jun Rao <junrao@gmail.com>
Authored: Fri Feb 22 18:48:14 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Fri Feb 22 18:48:14 2013 -0800

----------------------------------------------------------------------
 config/log4j.properties                            |    1 +
 .../main/scala/kafka/api/ProducerResponse.scala    |    2 -
 .../main/scala/kafka/network/RequestChannel.scala  |    2 +-
 .../main/scala/kafka/network/SocketServer.scala    |   30 +++++--
 .../scala/kafka/producer/BrokerPartitionInfo.scala |    2 +-
 .../scala/kafka/producer/ConsoleProducer.scala     |   10 ++-
 .../scala/kafka/producer/KafkaLog4jAppender.scala  |   13 ++-
 core/src/main/scala/kafka/producer/Producer.scala  |    2 +-
 .../main/scala/kafka/producer/SyncProducer.scala   |   17 +++-
 .../kafka/producer/async/DefaultEventHandler.scala |   30 ++++---
 core/src/main/scala/kafka/server/KafkaApis.scala   |    9 ++-
 .../unit/kafka/integration/PrimitiveApiTest.scala  |   48 ++++++++---
 .../integration/ProducerConsumerTestHarness.scala  |   14 +---
 .../scala/unit/kafka/log/OffsetIndexTest.scala     |    2 +-
 .../unit/kafka/log4j/KafkaLog4jAppenderTest.scala  |    7 +-
 .../unit/kafka/network/SocketServerTest.scala      |   36 +++++++-
 .../unit/kafka/producer/AsyncProducerTest.scala    |   13 ++--
 .../scala/unit/kafka/producer/ProducerTest.scala   |    3 +-
 .../unit/kafka/producer/SyncProducerTest.scala     |   69 +++++++--------
 .../scala/unit/kafka/server/LogRecoveryTest.scala  |    2 +-
 .../unit/kafka/server/ServerShutdownTest.scala     |    2 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |   25 ++++--
 22 files changed, 215 insertions(+), 124 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ccfdabc0/core/src/main/scala/kafka/producer/Producer.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/kafka/blob/ccfdabc0/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/kafka/blob/ccfdabc0/core/src/main/scala/kafka/server/KafkaApis.scala
----------------------------------------------------------------------


Mime
View raw message