in config/config.go [192:233]
func getDefaultConfig() *AppConfigODS {
return &AppConfigODS{
Port: 7836,
MaxNumProcs: runtime.NumCPU(),
StateDBName: types.MyDBName,
StateClusterName: types.MyClusterName,
StateUpdateInterval: 300 * time.Second,
WorkerIdleInterval: 30 * time.Second,
ChangelogPipeType: "kafka",
ChangelogTopicNameTemplateDefault: types.MySvcName + ".service.{{.Service}}.db.{{.DB}}.table.{{.Table}}{{if .Version}}.v{{.Version}}{{end}}",
OutputTopicNameTemplateDefault: "hp-tap-{{.Service}}-{{.DB}}-{{.Table}}{{if .Version}}-v{{.Version}}{{end}}",
ChangelogBuffer: true,
ChangelogWatchdogInterval: 300 * time.Second,
LogType: "std",
LogLevel: "info",
InternalEncoding: "json",
TableParams: TableParams{
Pipe: PipeConfig{
BaseDir: fmt.Sprintf("/var/lib/%s", types.MySvcName),
MaxFileSize: 1024 * 1024 * 1024,
MaxBatchSize: 4096,
MaxBatchSizeBytes: 32 * 1024 * 1024,
FileDelimited: true,
S3: S3Config{
Timeout: 7 * 24 * time.Hour,
},
Kafka: KafkaConfig{
MaxMessageBytes: 30 * 1024 * 1024,
},
},
},
ConfigRefreshInterval: 300 * time.Second,
}
}