Merge pull request #97 from akto-api-security/fix/kafka-callback-error

notshivansh · web-flow · commit c1daaa1f6579 · 2025-06-24T15:18:07.000+05:30
add actual kafka error
diff --git a/main.go b/main.go
@@ -874,7 +874,9 @@ func kafkaCompletion() func(messages []kafka.Message, err error) {
 	return func(messages []kafka.Message, err error) {
 		if err != nil {
 			kafkaErrMsgCount += len(messages)
-			log.Printf("kafkaErrMsgCount : %d, messagesCount %d", kafkaErrMsgCount, len(messages))
+			log.Printf("kafkaErrMsgCount : %d, messagesCount %d, error: %v", kafkaErrMsgCount, len(messages), err)
+		}else{
+			printLog(fmt.Sprintf("Successfully sent %d messages to Kafka", len(messages)))
 		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -874,7 +874,9 @@ func kafkaCompletion() func(messages []kafka.Message, err error) {`
`874`	`874`	`return func(messages []kafka.Message, err error) {`
`875`	`875`	`if err != nil {`
`876`	`876`	`kafkaErrMsgCount += len(messages)`
`877`		`- log.Printf("kafkaErrMsgCount : %d, messagesCount %d", kafkaErrMsgCount, len(messages))`
	`877`	`+ log.Printf("kafkaErrMsgCount : %d, messagesCount %d, error: %v", kafkaErrMsgCount, len(messages), err)`
	`878`	`+ }else{`
	`879`	`+ printLog(fmt.Sprintf("Successfully sent %d messages to Kafka", len(messages)))`
`878`	`880`	`}`
`879`	`881`	`}`
`880`	`882`	`}`