When i fire event, scala stream collector show
Stream Enrich shows
In Data Stream, we are getting records.
I have setup snowplow-s3-loader and run
java -jar snowplow-s3-loader-0.6.0.jar --config my.conf
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
[main] INFO com.snowplowanalytics.s3.loader.sinks.KinesisSink - Stream zanui-staging-snowplow-collected-bad-events-stream exists and is active
[main] INFO com.snowplowanalytics.s3.loader.SinkApp$ - Initializing sink with KinesisConnectorConfiguration: {regionName=ap-southeast-2, s3Endpoint=https://s3-ap-southeast-2.amazonaws.com, kinesisInputStream=*****-staging-snowplow-collected-good-events-stream, maxRecords=10000, connectorDestination=s3, bufferMillisecondsLimit=5000, bufferRecordCountLimit=10, s3Bucket=*****-staging-snowplow-enriched-good-events, kinesisEndpoint=https://kinesis.ap-southeast-2.amazonaws.com, appName=*****-enricher-app, bufferByteSizeLimit=1000000000, retryLimit=1, initialPositionInStream=AT_TIMESTAMP}
[main] INFO com.snowplowanalytics.s3.loader.KinesisSourceExecutor - KinesisSourceExecutor worker created
But nothing is loaded in S3 bucket why?
And only Scan: [Table] zanui-enricher-app: leaseKey is showing in DynamoDb.
Can anybody suggest me where i go wrong @PaulBoocock ?