python - 浮士德找不到话题
问题描述
我正在使用:python 3.8 faust==1.10.4 kafka==2.13-2.8.0
app = faust.App(
'kafka_faust',
autodiscover=True,
bootstrap_sever=KAFKA_SERVER,
)
test_topic = app.topic('test_read',
retention=datetime.timedelta(days=1),
value_serializer=json,
value_type=json,
partitions=8
)
但是,faust 的日志只显示而不显示其他主题
┌Requested Subscription───────────┐
│ topic name │
├─────────────────────────────────┤
│ kafka_faust-__assignor-__leader │
└─────────────────────────────────┘
我已经用 Kafka API 检查了主题“test_read”的存在。这是结果
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test_read
Topic: test_read PartitionCount: 3 ReplicationFactor: 1 Configs:
Topic: test_read Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: test_read Partition: 1 Leader: 0 Replicas: 0 Isr: 0
Topic: test_read Partition: 2 Leader: 0 Replicas: 0 Isr: 0
因此,这个话题肯定存在,而浮士德没有发现它。你有什么建议吗?为什么会这样?
解决方案
推荐阅读
- hyperledger-fabric - 我们可以在连接配置文件中使用定义的排序器覆盖发现的排序器吗?
- java - 如何将 http 请求回滚到将数据保存到 db 的 api 端点
- reporting-services - 3D 面积图 SSRS 报告第三轴
- powershell - 我们需要每天将“report assinement 09.09.2020.xlsx”(更改日期行 08.09.2020 等不)之类的文件重命名为 myproject.xlsx
- rust - 如何将 dyn FnMut 转换为自定义特征对象?
- java - Akka Streams - 为 mapAsync 定义超时
- list - 如何遍历MyBatis中的动态列表并访问列表的对象
- dataframe - 如何在 Spark 数据框中添加具有当前日期的额外列
- javascript - 试图在我的 React 应用程序中找到给定时间和当前时间的时差(以分钟为单位)
- javascript - 画布闪烁,img.src访问