Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 95a2368

Browse files
committedSep 13, 2017
Add message when requiring that the Kinesis stream exist fails (closes #113)
1 parent df5738b commit 95a2368

File tree

1 file changed

+1
-1
lines changed
  • src/main/scala/com.snowplowanalytics.snowplow.storage.kinesis/s3/sinks

1 file changed

+1
-1
lines changed
 

‎src/main/scala/com.snowplowanalytics.snowplow.storage.kinesis/s3/sinks/KinesisSink.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ class KinesisSink(
6969
.withEndpointConfiguration(new EndpointConfiguration(endpoint, region))
7070
.build()
7171

72-
require(streamExists(name))
72+
require(streamExists(name), s"Kinesis stream $name doesn't exist")
7373

7474
/**
7575
* Checks if a stream exists.

0 commit comments

Comments
 (0)
Please sign in to comment.