Temporary commit (amend me)

owenniles · owenniles · commit 3b27a4dce39e · 2024-07-15T15:50:12.000-04:00
diff --git a/processor.go b/processor.go
@@ -112,6 +112,8 @@ func NewProcessor(brokers []string, gg *GroupGraph, options ...ProcessorOption)
 			WithViewTopicManagerBuilder(opts.builders.topicmgr),
 			WithViewStorageBuilder(opts.builders.storage),
 			WithViewConsumerSaramaBuilder(opts.builders.consumerSarama),
+			WithViewHashUnsigned(),
+			WithViewAutoReconnect(),
 		)
 		if err != nil {
 			return nil, fmt.Errorf("error creating view: %v", err)

Original file line number	Diff line number	Diff line change
`@@ -112,6 +112,8 @@ func NewProcessor(brokers []string, gg *GroupGraph, options ...ProcessorOption)`
`112`	`112`	`WithViewTopicManagerBuilder(opts.builders.topicmgr),`
`113`	`113`	`WithViewStorageBuilder(opts.builders.storage),`
`114`	`114`	`WithViewConsumerSaramaBuilder(opts.builders.consumerSarama),`
	`115`	`+ WithViewHashUnsigned(),`
	`116`	`+ WithViewAutoReconnect(),`
`115`	`117`	`)`
`116`	`118`	`if err != nil {`
`117`	`119`	`return nil, fmt.Errorf("error creating view: %v", err)`