{"push_id":1264840134,"size":1,"distinct_size":1,"ref":"refs/heads/master","head":"ff76d8054cad49e481364953cce906a2358d32cc","before":"8b2a1cb4b007c7978f56247198132ab519d63f49","commits":[{"sha":"ff76d8054cad49e481364953cce906a2358d32cc","author":{"name":"Andrew Stevenson","email":"6b7c097d961f68685fc978cf91eeae17be6cbb45@datamountaineer.com"},"message":"merge cp-3.0.0 into master (#49)\n\n* upgrade to 3.0.0\r\n\r\n* move to confluent 3.0.0 and kafka 0.10.0\r\n\r\n* update to confluent 3.0\r\n\r\n* Update README.md\r\n\r\n* Adding collectJars task - to collect all dependencies into libs-dependencies folder\r\n\r\n* kudu clean up\r\n\r\n* Fix link to docs\r\n\r\nSince it 404'd\r\n\r\n* Fix link to docs\r\n\r\n* adding the influxdb sink\r\n\r\n* more unit tests\r\n\r\n* WIP hazelcast\r\n\r\n* WIP hazelcast\r\n\r\n* adding more logging\r\n\r\n* upgrading to KCQL 0.5\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* WIP - added writer\r\n\r\n* WIP scala style check\r\n\r\n* changing the logging to JUL\r\n\r\n* don't return null\r\n\r\n* don't return null\r\n\r\n* fixing the POLL_INTERVAL key\r\n\r\n* correcting logs\r\n\r\n* using an array blocking queue and adding a buffer size to the settings\r\n\r\n* handling exceptions for now to get the logs\r\n\r\n* trying out\r\n\r\n* trying out\r\n\r\n* using put not add on the blocking queue\r\n\r\n* improvng implementation\r\n\r\n* making sure we pass an offset to avoid the OffsetWriterStorage giving an error  \"is already flushing\"\r\n\r\n* fixing the build\r\n\r\n* fixing the build\r\n\r\n* fixing the build\r\n\r\n* added more logging\r\n\r\n* added more logging\r\n\r\n* trying to validate the records\r\n\r\n* trying to validate the records\r\n\r\n* trying to validate the records\r\n\r\n* trying to validate the records\r\n\r\n* trying to validate the records\r\n\r\n* fixing the schema for stocks\r\n\r\n* fixing the schema name\r\n\r\n* removing the avro schema validator\r\n\r\n* adding doc to the avro schema\r\n\r\n* fixing the unit test\r\n\r\n* supporting influxdb timestamp to be specified as one of the fields in the incoming SinkRecord\r\n\r\n* fixing the unit tests\r\n\r\n* fixing the sink startup\r\nadded more logging\r\n\r\n* adding more logging\r\n\r\n* upgrading to KCQL 0.5\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* adding more logging\r\n\r\n* WIP hazelcast\r\n\r\n* WIP hazelcast\r\n\r\n* changing the logging to JUL\r\n\r\n* don't return null\r\n\r\n* don't return null\r\n\r\n* fixing the POLL_INTERVAL key\r\n\r\n* correcting logs\r\n\r\n* using an array blocking queue and adding a buffer size to the settings\r\n\r\n* handling exceptions for now to get the logs\r\n\r\n* trying out\r\n\r\n* trying out\r\n\r\n* using put not add on the blocking queue\r\n\r\n* improvng implementation\r\n\r\n* making sure we pass an offset to avoid the OffsetWriterStorage giving an error  \"is already flushing\"\r\n\r\n* fixing the build\r\n\r\n* fixing the build\r\n\r\n* hazelcast sink and writer\r\n\r\n* hazelcast\r\n\r\n* adding the sink for voltdb\r\n\r\n* changing the ascii art\r\n\r\n* Update README.md\r\n\r\n* Create README.md\r\n\r\n* Create README.md\r\n\r\n* WIP hazelcast\r\n\r\n* WIP hazelcast\r\n\r\n* WIP - added writer\r\n\r\n* WIP hazelcast\r\n\r\n* WIP hazelcast\r\n\r\n* WIP scala style check\r\n\r\n* hazelcast sink and writer\r\n\r\n* hazelcast\r\n\r\n* fixing tests and readme\r\n\r\n* rebase  and cleanup check on assignment\r\n\r\n* Update README.md\r\n\r\n* adding KCQL support\r\n\r\nremoving unwanted file\r\n\r\n* moved from json4s to jacskon\r\nsmall fixes\r\n\r\n* adding support for sampling the records\r\n\r\n* enhancing the message sent over the socket to contain the topic ,partitition and the timestamp\r\n\r\n* fixing client connection\r\n\r\n* enhancing the code to support text,avro and binary payloads\r\n\r\n* allowing kafka client configs to be used if they are specified in the config under kafka.client root\r\n\r\n* removing the config entry for kafka client\r\n\r\n* fixes for style checker and voltdb call proc\r\n\r\n* fixing kcql for hazelcast\r\n\r\n* queries for _schemas topic share now the same kafka client","distinct":true,"url":"https://api.github.com/repos/datamountaineer/stream-reactor/commits/ff76d8054cad49e481364953cce906a2358d32cc"}]}
{"actor":{"display_login":"andrewstevenson"}}