{"project":"fht-edge","date":"2023-07-21 17:59:26","level":"ERROR","className":"com.fht.edge.gateway.infrastructure.util.KafkaMessageSenderUtils","thread":"Thread-23","msg":"kafka send error!","stackTrace":"org.springframework.kafka.KafkaException: Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic bjxxg_collect_meter_device_data not present in metadata after 60000 ms.\n\tat org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:573)\n\tat org.springframework.kafka.core.KafkaTemplate.send(KafkaTemplate.java:363)\n\tat com.fht.edge.gateway.infrastructure.util.KafkaMessageSenderUtils.sendDeviceRunData(KafkaMessageSenderUtils.java:68)\n\tat com.fht.edge.gateway.domain.service.task.thread.SendRunDataThreadRewrite.lambda$sendRunData$0(SendRunDataThreadRewrite.java:65)\n\tat java.util.ArrayList.forEach(ArrayList.java:1259)\n\tat com.fht.edge.gateway.domain.service.task.thread.SendRunDataThreadRewrite.sendRunData(SendRunDataThreadRewrite.java:63)\n\tat com.fht.edge.gateway.domain.service.task.thread.SendRunDataThreadRewrite.run(SendRunDataThreadRewrite.java:49)\nCaused by: org.apache.kafka.common.errors.TimeoutException: Topic bjxxg_collect_meter_device_data not present in metadata after 60000 ms.\n"}
时间: 2024-02-05 07:03:34 浏览: 47
根据提供的错误日志,可以看出出现了一个超时异常(TimeoutException),原因是在发送消息时,主题(topic)"bjxxg_collect_meter_device_data" 在元数据中找不到。
这可能是由于以下原因导致的问题:
1. 主题(topic)"bjxxg_collect_meter_device_data" 不存在。请确保该主题已经正确创建并且已经在 Kafka 中可用。
2. Kafka 配置不正确。请检查 Kafka 的配置文件,确保正确配置了 Kafka 的主机名、端口号、安全认证等信息。
3. 网络连接问题。请确保 Kafka 服务可以正常访问,并且网络连接是稳定的。
4. Kafka 集群中的主题(topic)分区不可用。如果主题(topic)存在,但分区不可用,可能需要重新分配分区或修复分区的问题。
建议您按照以下步骤进行排查:
1. 确认主题(topic)"bjxxg_collect_meter_device_data" 在 Kafka 中已经正确创建。
2. 检查 Kafka 的配置文件,确保配置正确。
3. 检查网络连接是否正常,确保能够正常访问 Kafka 服务。
4. 如果问题仍然存在,可以尝试重启 Kafka 服务,并检查日志以获取更多详细信息。
希望以上信息对您有帮助!如果您有更多问题,请随时提问。
相关问题
基2DIT-FHT算法python代码的实现
基于2DIT-FHT算法的Python代码实现如下:
```python
import numpy as np
def fht_2d(x):
n, m = x.shape
for i in range(n):
x[i, :] = fht(x[i, :])
for j in range(m):
x[:, j] = fht(x[:, j])
return x
def fht(x):
n = len(x)
if n == 1:
return x
even = fht(x[0::2])
odd = fht(x[1::2])
for i in range(n // 2):
x[i] = even[i] + odd[i]
x[i + n // 2] = even[i] - odd[i]
return x
```
上述代码中,我们首先对每一行进行一维FHT变换,然后对每一列进行一维FHT变换,从而实现二维FHT变换。在一维FHT变换中,我们采用了与快速傅里叶变换类似的分治思想,通过递归调用来实现。
There is no getter for property named 'list' in 'class com.dxjr.finance.fht.managed.dao.qo.BillQueryDTO'
There is no getter for property named 'list' in 'class com.dxjr.finance.fht.managed.dao.qo.BillQueryDTO'这个错误是由于在com.dxjr.finance.fht.managed.dao.qo.BillQueryDTO类中没有名为'list'的属性的getter方法导致的。要解决这个问题,你需要在BillQueryDTO类中添加一个名为'getList'的getter方法,并确保该方法正确返回'list'属性的值。