search

snowplow-archive / kinesis-example-scala-producer

Example Scala/SBT event producer for Amazon Kinesis
http://snowplowanalytics.com
21 stars 11 forks source link

Add logging output to the producer #2

Open alexanderdean opened 10 years ago

alexanderdean commented 10 years ago

Assigning to @bamos for consideration. @bamos please re-assign to Alex if you decide not to do this one.

bamos commented 10 years ago

https://github.com/snowplow/kinesis-example-scala-producer/commit/ccd44208c465c9ac981559256cc3d4eef3eb8836 adds a 'logging' option to give the following. Do you want something more sophisticated?

~/kinesis-example-scala-producer [feature/bamos-updates] » sbt "run --config my.conf --create"
Loading /usr/share/java/sbt/bin/sbt-launch-lib.bash
[info] Loading project definition from /home/brandon/docs/work/2013-2014/snowplow/repos/kinesis-example-scala-producer/project
[info] Set current project to kinesis-example-scala-producer (in build file:/home/brandon/docs/work/2013-2014/snowplow/repos/kinesis-example-scala-producer/)
[info] Compiling 1 Scala source to /home/brandon/docs/work/2013-2014/snowplow/repos/kinesis-example-scala-producer/target/scala-2.10/classes...
[info] Running com.snowplowanalytics.kinesis.producer.ProducerApp --config my.conf --create
Creating stream snowplow_thrift of size 1.
Successfully created stream.
Writing Thrift record.
  + data.name: example-record
  + data.timestamp: 33964
  + key: partition-key-33964
Writing successful.
  + ShardId: shardId-000000000000
  + SequenceNumber: 49535069328678124018856081559289455869039646785163755521
Writing Thrift record.
  + data.name: example-record
  + data.timestamp: 34153
  + key: partition-key-34153
Writing successful.
  + ShardId: shardId-000000000000
  + SequenceNumber: 49535069328678124018856080541967018079569776341187297281
Writing Thrift record.
  + data.name: example-record
  + data.timestamp: 34304
  + key: partition-key-34304
Writing successful.
  + ShardId: shardId-000000000000
  + SequenceNumber: 49535069328678124018856081731410806321679458138043973633
Writing Thrift record.
  + data.name: example-record
  + data.timestamp: 34431
  + key: partition-key-34431
Writing successful.
  + ShardId: shardId-000000000000
  + SequenceNumber: 49535069328678124018856081820813560822735189411345989633
Writing Thrift record.
  + data.name: example-record
  + data.timestamp: 34592
  + key: partition-key-34592
Writing successful.
  + ShardId: shardId-000000000000
  + SequenceNumber: 49535069328678124018856081778420316175732800647025655809
[success] Total time: 39 s, completed Dec 24, 2013 5:07:14 AM
alexanderdean commented 10 years ago

That looks awesome @bamos !