fix

Author: VPolka

cmd/aardappel/main.go

@@ -199,7 +199,7 @@ func doMain(ctx context.Context, config configInit.Config, srcDb *client.TopicCl
 
 	for i := 0; i < len(config.Streams); i++ {
 		cfgStream := &config.Streams[i]
-		startCb, updateCb := topicReader.MakeTopicReaderGuard()
+		startCb, updateCb := topicReader.MakeTopicReaderGuard(errChannel)
 		reader, err := srcDb.StartReader(config.Streams[i].Consumer, cfgStream.SrcTopic,
 			topicoptions.WithReaderGetPartitionStartOffset(startCb))