Code

Fix compression timestamps#759

Code

Merged

eapache merged 4 commits intoIBM:masterIBM/sarama:masterfrom rtreffer:fix-compression-timestampsrtreffer/sarama:fix-compression-timestampsCopy head branch name to clipboardOct 6, 2016

+55-4

Commits

Commits on Oct 5, 2016

• Add test for broken message version if compression is enabled.

  rtreffer-sc

  committed
  f7ed0d9

• Fix message version/timestamp for compressed messages on kafka >= 0.10.0.0

  rtreffer-sc

  committed
  b1f4708

Commits on Oct 6, 2016

• Use default timestamp of time.Now and message version 1 if possible

  rtreffer-sc

  committed
  425aaad

• Approximate timestamp of compressed message

  Show description for 413f13f
  rtreffer-sc

  committed
  413f13f