Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 28, 2013

• remove batchSize loop in source

  

  frank.yao

  committed
  ec179fb

  Copy full SHA for ec179fb

Commits on Nov 22, 2013

• use general try-catch in sink

  

  frank.yao

  committed
  dff9d65

  Copy full SHA for dff9d65

Commits on Nov 8, 2013

• modify log format

  

  frank.yao

  committed
  e3bd22f

  Copy full SHA for e3bd22f

• update log4j

  

  frank.yao

  committed
  02b15fa

  Copy full SHA for 02b15fa

Commits on Nov 7, 2013

• params are now handled by user's conf, flume-kafka will not keep default value of kafka config

  

  frank.yao

  committed
  94f5ca0

  Copy full SHA for 94f5ca0

• log context

  

  frank.yao

  committed
  71cb9b8

  Copy full SHA for 71cb9b8

• adjust package structure

  

  frank.yao

  committed
  e59cd32

  Copy full SHA for e59cd32

• update Producer Params

  

  frank.yao

  committed
  c028c24

  Copy full SHA for c028c24

• update Consumer Constatns and its default value

  

  frank.yao

  committed
  0b412d4

  Copy full SHA for 0b412d4

• fix name bus

  

  frank.yao

  committed
  ac77a61

  Copy full SHA for ac77a61

• split KafkaConstants to ConsumerConstants and ProducerConstants

  

  frank.yao

  committed
  37c7362

  Copy full SHA for 37c7362

Commits on Nov 4, 2013

• init branch

  

  frank.yao

  committed
  145a7ad

  Copy full SHA for 145a7ad

• add *.class to ignore

  

  frank.yao

  committed
  b6e7bc4

  Copy full SHA for b6e7bc4

Commits on Sep 2, 2013

• comment fetch.size attr

  

  frank.yao

  committed
  0e342f4

  Copy full SHA for 0e342f4

Commits on Aug 20, 2013

• enable fetch.size

  

  frank.yao

  committed
  7b40aab

  Copy full SHA for 7b40aab

• disable fetch.size

  

  frank.yao

  committed
  3e07864

  Copy full SHA for 3e07864

Commits on Aug 19, 2013

• add zk.sessiontimeout.ms to comsumer

  

  frank.yao

  committed
  97dc56b

  Copy full SHA for 97dc56b

Commits on Aug 6, 2013

• add timeout params

  

  frank.yao

  committed
  1d7f370

  Copy full SHA for 1d7f370

Commits on Jul 25, 2013

• add queue.size in async producer

  

  frank.yao

  committed
  4012995

  Copy full SHA for 4012995

• use batchsize in kafka consumer

  

  frank.yao

  committed
  5f10a51

  Copy full SHA for 5f10a51

Commits on Jul 24, 2013

• remove classes in gitignore

  

  frank.yao

  committed
  44773bb

  Copy full SHA for 44773bb

• enable autocommit

  

  frank.yao

  committed
  073cc1b

  Copy full SHA for 073cc1b

Commits on Jul 12, 2013

• debug message for each event move to trace level

  

  root

  committed
  75d01a3

  Copy full SHA for 75d01a3

Commits on Jul 3, 2013

• change zk.sessiontimeout to a customize value

  

  frankyao

  authored and

  frankyao

  committed
  edeb84a

  Copy full SHA for edeb84a

• use zk.sessiontimeout.ms

  

  frankyao

  authored and

  frankyao

  committed
  ebf5722

  Copy full SHA for ebf5722

Commits on Jun 6, 2013

• fix a fetal bug in KafkaUtil.java caused by a int 15000

  

  frankyao

  authored and

  frankyao

  committed
  06b3eac

  Copy full SHA for 06b3eac

Commits on Jun 3, 2013

• add zk.connectiontimeout.ms arg

  

  frankyao

  authored and

  frankyao

  committed
  88249f3

  Copy full SHA for 88249f3

Commits on May 27, 2013

• disable zk commit

  

  frankyao

  authored and

  frankyao

  committed
  d3c9b22

  Copy full SHA for d3c9b22

• fix wrong attribute name: autooffset

  

  frankyao

  authored and

  frankyao

  committed
  acd0be5

  Copy full SHA for acd0be5

Commits on May 20, 2013

• update log4j

  

  frankyao

  authored and

  frankyao

  committed
  f0e3490

  Copy full SHA for f0e3490

Commits on May 17, 2013

• enable logic

  

  frankyao

  authored and

  frankyao

  committed
  7be470a

  Copy full SHA for 7be470a

• comment logic in process()

  

  frankyao

  authored and

  frankyao

  committed
  c5b82a4

  Copy full SHA for c5b82a4

• move some variable outof loop in process()

  

  frankyao

  authored and

  frankyao

  committed
  2f0f264

  Copy full SHA for 2f0f264

• enlarge the buffersize

  

  frankyao

  authored and

  frankyao

  committed
  fe4fd14

  Copy full SHA for fe4fd14

• add autooffset

  

  frankyao

  authored and

  frankyao

  committed
  c913086

  Copy full SHA for c913086

Pagination

Previous

Next