Skip to content

Commit 243b790

Browse files
author
ffffwh
committed
add API kafka config DateTimeZone #1043
1 parent 192b3e2 commit 243b790

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

api/handler/v2/job.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -622,6 +622,7 @@ func buildDatabaseSrcTaskConfigMap(config *models.SrcTaskConfig, destConfig *mod
622622
kafkaMap["MessageGroupMaxSize"] = kafkaConfig.MessageGroupMaxSize
623623
kafkaMap["MessageGroupTimeout"] = kafkaConfig.MessageGroupTimeout
624624
kafkaMap["Converter"] = kafka.CONVERTER_JSON
625+
kafkaMap["DateTimeZone"] = kafkaConfig.DateTimeZone
625626
taskConfigInNomadFormat["KafkaConfig"] = kafkaMap
626627
}
627628

@@ -1433,6 +1434,7 @@ func buildKafkaDestTaskDetail(taskName string, internalTaskKafkaConfig common.Ka
14331434
Topic: internalTaskKafkaConfig.Topic,
14341435
MessageGroupMaxSize: internalTaskKafkaConfig.MessageGroupMaxSize,
14351436
MessageGroupTimeout: internalTaskKafkaConfig.MessageGroupTimeout,
1437+
DateTimeZone: internalTaskKafkaConfig.DateTimeZone,
14361438
}
14371439

14381440
for _, a := range allocsFromNomad {

api/models/job_v2.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -232,6 +232,7 @@ type KafkaDestTaskConfig struct {
232232
NodeId string `json:"node_id,omitempty"`
233233
BrokerAddrs []string `json:"kafka_broker_addrs" validate:"required" example:"127.0.0.1:9092"`
234234
Topic string `json:"kafka_topic" validate:"required"`
235+
DateTimeZone string `json:"kafka_date_time_zone"`
235236
MessageGroupMaxSize uint64 `json:"message_group_max_size"`
236237
MessageGroupTimeout uint64 `json:"message_group_timeout"`
237238
}

0 commit comments

Comments
 (0)