Skip to content

Commit

Permalink
all integration stream tests now run with different application-ids
Browse files Browse the repository at this point in the history
  • Loading branch information
@theanirudhvyas
theanirudhvyas committed Mar 25, 2019
1 parent 523d60b commit 488abc1
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions test/ziggurat/streams_test.clj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@
oldest-processed-message-in-s 10
kvs (repeat times message-key-value)
streams (start-streams {:vehicle {:handler-fn mapped-fn}} (-> config-map
(assoc-in [:stream-router :vehicle :bootstrap-servers] (get-in config-map [:stream-router :vehicle :bootstrap-servers]))
(assoc-in [:stream-router :vehicle :application-id] (str "test" "-" (rand-int 999999999)))
(assoc-in [:stream-router :vehicle :oldest-processed-message-in-s] oldest-processed-message-in-s)
(assoc-in [:stream-router :vehicle :origin-topic] topic)))]
(Thread/sleep 20000) ;;waiting for streams to start
Expand All @@ -65,7 +65,7 @@
times 6
kvs (repeat times message-key-value)
streams (start-streams {:vehicle {:handler-fn mapped-fn}} (-> config-map
(assoc-in [:stream-router :vehicle :bootstrap-servers] (get-in config-map [:stream-router :vehicle :bootstrap-servers]))
(assoc-in [:stream-router :vehicle :application-id] (str "test" "-" (rand-int 999999999)))
(assoc-in [:stream-router :vehicle :origin-topic] topic)))]
(Thread/sleep 20000) ;;waiting for streams to start
(IntegrationTestUtils/produceKeyValuesSynchronously topic kvs props (MockTime.))
Expand Down

0 comments on commit 488abc1

Please sign in to comment.