fix: 相关测试配置
This commit is contained in:
@@ -85,7 +85,7 @@ func (s *TestController) Demo(c *gin.Context) {
|
||||
return
|
||||
}
|
||||
if body.OperType == "performance" {
|
||||
err := s.performanceService.PerformanceUploadOSS("SMF", "2024-03-20 19:00:05", "2024-03-20 19:50:05")
|
||||
err := s.performanceService.PerformanceUploadOSS("AMF", "2024-07-12 16:00:05", "2024-07-12 17:00:05")
|
||||
c.JSON(200, map[string]any{
|
||||
"requestId": body.RequestId,
|
||||
"operType": body.OperType,
|
||||
|
||||
@@ -97,7 +97,6 @@ func (s *AlarmImpl) KafkaPush(alarm neDataModel.Alarm) error {
|
||||
// 发送消息
|
||||
partition, offset, err := kafka.KInitConm.MessageSyncSend(topic, 0, string(bytes))
|
||||
if err != nil {
|
||||
logger.Errorf("KafkaPush MessageSyncSend err => %s", err.Error())
|
||||
return err
|
||||
}
|
||||
logger.Infof("KafkaPush MessageSyncSend Partition:%d, Offset:%d", partition, offset)
|
||||
|
||||
Reference in New Issue
Block a user