Revert "Set an initial timestamp for new Kinesis streams"
This commit is contained in:
parent
6d83fc3212
commit
b5767ebf90
@ -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"`
|
||||
}
|
||||
|
||||
@ -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)
|
||||
|
||||
Loading…
Reference in New Issue
Block a user