Code

Changes to work with kafka 0.8#7

Code

Open

whitedr wants to merge 8 commits intoendgameinc:masterendgameinc/elasticsearch-river-kafka:masterfrom whitedr:masterwhitedr/elasticsearch-river-kafka:masterCopy head branch name to clipboard

+1,416-1,261

Commits

Commits on Jan 14, 2014

• updating code so that it will work with 0.8.0

  

  Warner Onstine

  committed
  28e49bf

  Copy full SHA for 28e49bf

Commits on Jan 16, 2014

• Fix mvn deps for kafka 0.8.0 to target scala 2.9.2. Fix KafkaClient.fetch to translate and throw exceptions on error in the FetchResponse. Add support for new river configuration named 'startFromNe…

  Show description for 115f362
  

  Dave White

  committed
  115f362

  Copy full SHA for 115f362

Commits on Jan 24, 2014

• Change move dumpStats within try/catch so river doesn't stop on socket timeout exceptions

  

  Dave White

  committed
  9c099f5

  Copy full SHA for 9c099f5

Commits on Mar 4, 2014

• null check on thread during river close

  

  Dave White

  committed
  9fb7299

  Copy full SHA for 9fb7299

Commits on Mar 12, 2014

• Version upgrades, fix tests

  Show description for 7ca6e96
  guenter

  committed
  7ca6e96

  Copy full SHA for 7ca6e96

• tabs -> spaces

  guenter

  committed
  ab3429a

  Copy full SHA for ab3429a

Commits on Apr 24, 2014

• Add support for multiple rivers running in different ES clusters by incorporating the configured river name in the location in zk where the offsets are stored.

  

  Dave White

  committed
  0ec5a69

  Copy full SHA for 0ec5a69

Commits on May 2, 2014

• Change river to:

  Show description for 1d2056e
  

  Dave White

  committed
  1d2056e

  Copy full SHA for 1d2056e