Code

Adding Kafka-emitter#3860

Code

Merged

fjy merged 28 commits intoapache:masterapache/druid:masterfrom dkhwangbo:kafka-emitterdkhwangbo/druid:kafka-emitterCopy head branch name to clipboardApr 4, 2017

+676

Commits

Commits on Mar 27, 2017

• Initial commit

  dkhwangbo

  committed
  5dd63e2

  Copy full SHA for 5dd63e2

• Apply another config: clustername

  dkhwangbo

  committed
  a303a1f

  Copy full SHA for a303a1f

• Rename variable

  dkhwangbo

  committed
  e911b35

  Copy full SHA for e911b35

• Fix bug

  dkhwangbo

  committed
  18126b9

  Copy full SHA for 18126b9

• Add retry logic

  dkhwangbo

  committed
  5ddbdb7

  Copy full SHA for 5ddbdb7

• Edit retry logic

  dkhwangbo

  committed
  5e634d3

  Copy full SHA for 5e634d3

• Upgrade kafka-clients version to the most recent release

  dkhwangbo

  committed
  efc938d

  Copy full SHA for efc938d

• Make callback single object

  dkhwangbo

  committed
  86fcb78

  Copy full SHA for 86fcb78

• Write documentation

  dkhwangbo

  committed
  887b293

  Copy full SHA for 887b293

• Rewrite error message and emit logic

  dkhwangbo

  committed
  e6fa868

  Copy full SHA for e6fa868

• Handling AlertEvent

  dkhwangbo

  committed
  80ccfb8

  Copy full SHA for 80ccfb8

• Override toString()

  dkhwangbo

  committed
  4bf0a69

  Copy full SHA for 4bf0a69

• make clusterName more optional

  dkhwangbo

  committed
  e635bbf

  Copy full SHA for e635bbf

• bump up druid version

  dkhwangbo

  committed
  01800f2

  Copy full SHA for 01800f2

• add producer.config option which make user can apply another optional config value of kafka producer

  dkhwangbo

  committed
  ea12d92

  Copy full SHA for ea12d92

• remove potential blocking in emit()

  dkhwangbo

  committed
  8d1e80c

  Copy full SHA for 8d1e80c

• using MemoryBoundLinkedBlockingQueue

  dkhwangbo

  committed
  2d9178c

  Copy full SHA for 2d9178c

• Fixing coding convention

  dkhwangbo

  committed
  e4fb6eb

  Copy full SHA for e4fb6eb

• Remove logging every exception and just increment counting

  dkhwangbo

  committed
  4d316ae

  Copy full SHA for 4d316ae

• refactoring

  dkhwangbo

  committed
  c7e8fce

  Copy full SHA for c7e8fce

• trivial modification

  dkhwangbo

  committed
  e1706f7

  Copy full SHA for e1706f7

• logging when callback has exception

  dkhwangbo

  committed
  6b383ea

  Copy full SHA for 6b383ea

• Replace kafka-clients 0.10.1.1 with 0.10.2.0

  dkhwangbo

  committed
  1408124

  Copy full SHA for 1408124

• Resolve the problem related of classloader

  dkhwangbo

  committed
  d2058d5

  Copy full SHA for d2058d5

• adopt try statement

  dkhwangbo

  committed
  ecb5c69

  Copy full SHA for ecb5c69

• code reformatting

  dkhwangbo

  committed
  3a4ca9f

  Copy full SHA for 3a4ca9f

• make variables final

  dkhwangbo

  committed
  8be4c4c

  Copy full SHA for 8be4c4c

• rewrite toString

  dkhwangbo

  committed
  f02218a

  Copy full SHA for f02218a