Fixing most of the issues jordan identified(CloudWatch/LOGSTASH-461) - moving 3rd party requires into register() - Using do...end instead of {...} for large blocks - using SizedQueue instead of Queue - using event.sprintf to normalize the timestamp - renaming send to publish - using while instead of until - improving how event fields are read
Fixing most of the issues jordan identified(CloudWatch/LOGSTASH-461)
- moving 3rd party requires into register()
- Using do...end instead of {...} for large blocks
- using SizedQueue instead of Queue
- using event.sprintf to normalize the timestamp
- renaming send to publish
- using while instead of until
- improving how event fields are read

opentable/logstash-kafka,joekiller/logstash-kafka,Aloomaio/logstash-kafka,tinglinux/logstash-kafka,tinglinux/logstash-kafka,joekiller/logstash-kafka,Aloomaio/logstash-kafka,opentable/logstash-kafka