Merge pull request #11 from 3lvia/bugfix/TKP-9291-401-fix

TKP-9291 adds panic if upsert to sf fails in order to restart applica…
3lvia · Feb 7, 2024 · 3d51106 · 3d51106
2 parents 39cea59 + bf57a00
commit 3d51106
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/sfkafkalib/kafka/kafkaconsumer.go b/pkg/sfkafkalib/kafka/kafkaconsumer.go
@@ -69,10 +69,12 @@ func CreateKafkaConsumer(ctx context.Context, conf *configuration.ConsumerConfig
 				fmt.Println("CONSUMING MESSAGE: " + message.Key__c)
 				if err := handleFunc(ctx, message); err != nil {
 					log.Sugar().ErrorwContext(ctx, "error in kafka handler", zap.Error(err))
+					panic(message)
 				}
 			case err := <-errChan:
 				fmt.Println("ERROR")
 				log.Sugar().ErrorwContext(ctx, "error in kafka handler", zap.Error(err))
+				panic(err)
 			}
 		}
 	}(ctx, outChan, errChan)