Cant put data in Kinesis
Conf file : <source> type forward port 24224 </source> <source> type http port 8282 </source> <source> type tail format apache2 path /var/log/httpd/access_log pos_file /var/log/httpd/access.log tag kinesis.access </source> <match fluent.> type stdout </match> <match kinesis.> type kinesis_alt aws_key_id AKIAIRIDNC5RPHWHWY2A aws_sec_key CoUJPyDFB491x4YZ7Ib7hBAcs0CRHDwL6anFl1ek region us-east-1 stream_name Fluentd partition_key Fd </match>
Test Command : echo '{"json":"message"}' | ./fluent-cat kinesis.apache -h 54.158.130.146
Im getting following error
fluent/output.rb:349:rescue in try_flush: temporarily failed to flush the buffer. next_retry=2015-03-23 09:31:09 +0000 error_class="AWS::Kinesis::Errors::ValidationException" error="1 validation error detected: Value '' at 'partitionKey' failed to satisfy constraint: Member must have length greater than or equal to 1" plugin_id="object:11e3e5c"
Comments (4)
-
-
repo owner I'm sorry. This plug-in has been merged into the awslabs/aws-fluent-plugin-kinesis. Please try the awslabs/aws-fluent-plugin-kinesis.
-
But when i m using Type-Kinesis It is giving me the following error config error file="/etc/fluent/fluent.conf" error="Unknown output plugin 'kinesis'. Run 'gem search -rd fluent-plugin' to find plugins" I have installed the plugin from git clone https://github.com/awslabs/aws-fluent-plugin-kinesis.git
-
Account Deactivated You should recycle your keys since you are pasting your AWS access keys on the internet
- Log in to comment
All configurations have been met
Its tailing the input but cant put data in Kinesis Plzzz help me out