Commit 717a7dc prateek.khatri
committed
1 parent 4b226a7 commit 717a7dc Copy full SHA for 717a7dc
File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 45
45
value "Hello World!!"
46
46
partition (int 0)]
47
47
(send :default topic partition key value)
48
- (let [result (IntegrationTestUtils/waitUntilMinKeyValueRecordsReceived *consumer-properties* topic 1 5000 )]
48
+ (let [result (IntegrationTestUtils/waitUntilMinKeyValueRecordsReceived *consumer-properties* topic 1 7000 )]
49
49
(is (= value (.value (first result))))))))
50
50
51
51
(deftest send-throws-exception-when-no-producers-are-configured
75
75
value "Hello World!!"]
76
76
(.reset tracer)
77
77
(send :default topic key value)
78
- (let [result (IntegrationTestUtils/waitUntilMinKeyValueRecordsReceived *consumer-properties* topic 1 5000 )
78
+ (let [result (IntegrationTestUtils/waitUntilMinKeyValueRecordsReceived *consumer-properties* topic 1 7000 )
79
79
finished-spans (.finishedSpans tracer)]
80
80
(is (= value (.value (first result))))
81
81
(is (= 1 (.size finished-spans)))
You can’t perform that action at this time.
0 commit comments