bkao issues

Repositories
Issues
Comments

Results 2 issues of


                                            bkao

fix typo, encoding

added a set_offset() method to partition_consumer.rb

When Kafka has a corrupt message poseidon gets stuck attempting to read the same offset ad infinitum. We needed to be able to skip ahead (presumably past a corrupt message...