Retrieving partitionkey via logstash-input-kinesis

We are trying to use logstash-input-kinesis to ingest data from AWS Kinesis into Elasticsearch. Here is our logstash pipeline:

input {
codec=> json
region=> "us-west-2"
metrics=> cloudwatch
type => "kinesisinput"
output {
if [type]=="kinesisinput" {
elasticsearch {
action => "index"
hosts => ["zzz"]
index => "events"
document_type => "kinesis"

Messages from the "xxx" stream in Kinesis get ingested successfully into Elasticsearch, except that the partitionkey associated with each message is missing. I'd like to know how to retrieve the partitionkey from the stream. Thanks.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.