A Ruby interface for the Amazon Kinesis Client Library. Allows developers to easily create robust application to process Amazon Kinesis streams in Ruby.
Configure dependabot to scan out-of-date dependencies
Update the setup logic to parse dependencies from mock pom.xml file
Fix import errors in the sample application
Testingproducer
rake run_producer
Running the Kinesis sample producer application...
/Volumes/workplace/kcl/amazon-kinesis-client-ruby/samples/sample_kcl_producer.rb
Stream kclrbsample already exists with 2 shards
Put record to shard 'shardId-000000000000' (49625052214701446996797992067786665837460769363023888386): '{"time":"1640802182.4140239","sensor":"snsr-0117","reading":"590297"}'
Put record to shard 'shardId-000000000000' (49625052214701446996797992068206163096867045686646931458): '{"time":"1640802182.790307","sensor":"snsr-0855","reading":"608302"}'
...
consumer
rake run properties_file=sample.properties
Running the Kinesis sample processing application...
...
2021-12-29 10:23:53,796 [multi-lang-daemon-0001] ERROR s.a.k.multilang.DrainChildSTDERRTask [NONE] - Received error line from subprocess [ShardId: shardId-000000000001, Partition Key: snsr-0696, Sequence Number:49625052214723747741996522693061955627353238355325222930, Length of data: 69] for shard shardId-000000000001
ShardId: shardId-000000000001, Partition Key: snsr-0696, Sequence Number:49625052214723747741996522693061955627353238355325222930, Length of data: 69
...
Note the logline in the sample consumer is flushed though stderr
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.
Issue #, if available:
Description of changes:
pom.xmlfileTesting
producerconsumerstderrBy submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.