Merge pull request #3 from Hinge/find-header

Add Confluent header to find
Hinge · Nov 8, 2022 · 60cdec5 · 60cdec5
2 parents 3aec5ed + e6dfa17
commit 60cdec5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cmd/kaf/query.go b/cmd/kaf/query.go
@@ -18,6 +18,7 @@ func init() {
 	queryCmd.Flags().StringVarP(&keyFlag, "key", "k", "", "Key to search for")
 	queryCmd.Flags().StringSliceVar(&protoFiles, "proto-include", []string{}, "Path to proto files")
 	queryCmd.Flags().StringSliceVar(&protoExclude, "proto-exclude", []string{}, "Proto exclusions (path prefixes)")
+	queryCmd.Flags().BoolVar(&confluentHeader, "confluent-header", false, "Force deserialization of messages with confluent headers (use if header detection fails)")
 	queryCmd.Flags().StringVar(&protoType, "proto-type", "", "Fully qualified name of the proto message type. Example: com.test.SampleMessage")
 	queryCmd.Flags().StringVar(&keyProtoType, "key-proto-type", "", "Fully qualified name of the proto key type. Example: com.test.SampleMessage")