Skip to content

Commit

Permalink
Increase sleep before closing stream as well as the join window ms
Browse files Browse the repository at this point in the history
  • Loading branch information
Anmol Vijaywargiya committed Aug 10, 2021
1 parent 8e4693e commit 7486237
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 @@ -294,7 +294,7 @@
(-> (ziggurat-config)
(assoc-in [:stream-router :default :consumer-type] :stream-joins)
(assoc-in [:stream-router :default :input-topics] {:topic {:name "topic"} :another-test-topic {:name "another-test-topic"}})
(assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 5000 :join-type :outer}})
(assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 6000 :join-type :outer}})
(assoc-in [:stream-router :default :application-id] (rand-application-id))
(assoc-in [:stream-router :default :changelog-topic-replication-factor] changelog-topic-replication-factor)))]
(Thread/sleep 10000) ;;waiting for streams to start
Expand All @@ -306,7 +306,7 @@
kvs
(props)
(MockTime.))
(Thread/sleep 5000) ;;wating for streams to consume messages
(Thread/sleep 10000) ;;wating for streams to consume messages
(stop-streams streams)
(is (= times @message-received-count)))))))

Expand Down

0 comments on commit 7486237

Please sign in to comment.