diff --git a/cmd/internal/config/config.go b/cmd/internal/config/config.go index 44e71d8..251fc9e 100644 --- a/cmd/internal/config/config.go +++ b/cmd/internal/config/config.go @@ -129,8 +129,6 @@ type StreamConfig struct { E164StreamName envstr `yaml:"e164-stream-name"` UsernameStreamName envstr `yaml:"username-stream-name"` - NewStreams []string `yaml:"new-streams"` - // If TableName is not provided, backfill will not be attempted. TableName envstr `yaml:"table"` } diff --git a/cmd/kt-server/main.go b/cmd/kt-server/main.go index 0b54395..72cb053 100644 --- a/cmd/kt-server/main.go +++ b/cmd/kt-server/main.go @@ -17,7 +17,6 @@ import ( "os" "os/signal" "runtime" - "slices" "syscall" "time" @@ -208,11 +207,6 @@ func main() { var streamStartTimestamp *time.Time if backfillStreamStartTimestamp != nil { streamStartTimestamp = backfillStreamStartTimestamp - } else { - if slices.Contains(config.StreamConfig.NewStreams, streamName) { - start := time.Now().Add(-time.Minute * 15) - streamStartTimestamp = &start - } } util.Log().Infof("Starting stream processing from Kinesis stream: %s", streamName)