小编Ash*_*Ash的帖子

谁跟踪 Apache Kafka 中消费者最后读取的消息偏移量?

在 Apache Kafka 中,谁跟踪消费者读取的最后一条消息?谁还跟踪从哪个分区读取哪个消费者组 ID?所有这些信息都在动物园管理员中吗?

apache-kafka kafka-consumer-api

5
推荐指数
1
解决办法
1915
查看次数

如何检查模拟函数在 clojure with_redefs 中使用给定参数至少调用一次?

test-service/process如果不调用,我在下面编写的测试不会失败。而且它也不检查 URL 和参数是否正确。

(deftest main-func-test
    (let [event {:a 123}]
      (with-redefs
        [test-service/process (fn [url params] response)]
        (is (= :success (main/main-func event)))))
Run Code Online (Sandbox Code Playgroud)

在红宝石中这很简单

expect(test_service).to receive(:process).with(url, params).and_return(response)
Run Code Online (Sandbox Code Playgroud)

如何test-service/process在 Clojure 中检查是否使用两个参数 URL 和 params 至少调用一次?

clojure clojure.spec

1
推荐指数
1
解决办法
433
查看次数