apache-kafka - 似乎无法让 EmbeddedSingleNodeKafkaCluster 运行
问题描述
我正在尝试为使用 Kafka 生产者和消费者的应用程序编写一些单元和集成测试。我想使用可用于启动 1 个 ZK 和 1 个 Kafka 代理的类来运行 EmbeddedSingleNodeKafkaCluster。我无法这样做 - 它无法启动集群并且我无法创建 Kafka Producer。
有没有人遇到过这个问题，如果有，您对编写单元/集成测试有何看法？
解决方案
推荐阅读
- vim - 在 Vim 中自动显示函数文档
- automation - 利用宏在 bigquery 上的多个模式上不再在 dbt 中删除旧关系
- algorithm - 最近邻搜索的二维树实现苦苦挣扎
- python-3.x - FastApi 为我的一个参数返回“必填字段”和“value_error.missing”，但该字段存在
- r - 识别 R 图中的值
- npm - npm lock-file 锁定包版本
- ios - UIPickerView 中的 UILabel 上的额外空间
- c++ - 如果参数包右侧包含简单类型参数，为什么可变参数模板参数包保持相同大小？
- r - 使用 dplyr 对两列数据框中的对象进行分类
- unit-testing - 测试在其主体中调用 boto3 的函数时如何模拟 boto3 调用