Description
In the KinesisFirehoseProducer.createRequest() method, you have this line:
~~~~
putRecordRequest.setDeliveryStreamName(getEndpoint().getEndpointKey());
~~~~
but the deliverStreamName should be set using getEndpoint().getStreamName()
Attachments
Issue Links
- links to