Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on May 15, 2015

• do not print the entire kafka payload on error :-/ + better recovery code

  quipo

  committedMay 15, 2015
  7032c3b

Commits on May 12, 2015

• git conflict woes :-/

  quipo

  committedMay 12, 2015
  f61e325

• fixed bug handling incomplete messages at end of batch; resume consumer when the current kafka segment is deleted prematurely

  quipo

  committedMay 12, 2015
  f5c2ddf

• fixed bug handling incomplete messages at end of batch; resume consumer when the current kafka segment is deleted prematurely

  quipo

  committedMay 12, 2015
  66c638b

Commits on Apr 30, 2015

• Now print hex dump in the event of a malformed packet error

  cjgdev

  committedApr 30, 2015
  484dbc4

Commits on Apr 28, 2015

• also print hex payload in case of fatal error

  quipo

  committedApr 28, 2015
  af9482d

• better debug logging

  quipo

  committedApr 28, 2015
  ce5ef41

• better distinction between DEBUG and ERROR logs

  quipo

  committedApr 28, 2015
  94aa7fd

Commits on Apr 15, 2015

• log overall consumer offset

  quipo

  committedApr 15, 2015
  722f948

• debug logging: print latest valid offset

  quipo

  committedApr 15, 2015
  7fa22f6

Commits on Apr 2, 2015

• remove useless code

  quipo

  committedApr 2, 2015
  f34eee5

• golint: Added comments + renamed Message.Id() to Message.ID(); added Snappy lib dependency in Travis config

  quipo

  committedApr 2, 2015
  0fb79d5

• refactoring of message iteration logic, with error constants, and identification of partial messages so we can issue a new fetch request in a clean way, without having to read every single group of…

  quipo

  committedApr 2, 2015
  93924f5

Commits on Apr 1, 2015

• better logging

  quipo

  committedApr 1, 2015
  cac0a48

Commits on Mar 30, 2015

• split "asked to quit" channel from "quit due to internal error" channel

  quipo

  committedMar 30, 2015
  392609d

Commits on Nov 24, 2014

• Adding a func to return the current offset for a broker.

  

  Jeremy Sherling

  authored and

  Lorenzo Alberton

  committedNov 24, 2014
  5edc1f1

Commits on Sep 24, 2013

• updated to work with go get

  jdamick

  committedSep 24, 2013
  6dbb918

Loading