Stream Enrich: make Kafka sink more fault tolerant by allowing retries

[simplesteph]

See here:

snowplow/2-collectors/scala-stream-collector/src/main/scala/com.snowplowanalytics.snowplow.collectors/scalastream/sinks/KafkaSink.scala

Line 60 in e977c97

props.put("retries", "0")

Would be great to have an optional param in config to set the number of retries.

That might bring up duplicates, as the docs says though (https://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html):

If the request fails, the producer can automatically retry, though since we have specified retries as 0 it won't. Enabling retries also opens up the possibility of duplicates (see the documentation on message delivery semantics for details).

[alexanderdean]

Good idea! Scheduling