Merge pull request #763 from marle3003/develop

marle3003 · web-flow · commit 9fcedb3d9cb5 · 2025-12-02T19:41:53.000+01:00
Develop
diff --git a/providers/asyncapi3/kafka/store/client.go b/providers/asyncapi3/kafka/store/client.go
@@ -162,7 +162,7 @@ func (c *Client) Read(topic string, partition int, offset int64, ct *media.Conte
 		return nil, fmt.Errorf("read records failed: %v", errCode.String())
 	}
 
-	var records []Record
+	records := make([]Record, 0)
 	var getValue func(value []byte) (any, error)
 	switch {
 	case ct.Key() == "application/vnd.mokapi.kafka.binary+json":

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ func (c Client) Read(topic string, partition int, offset int64, ct media.Conte`
`162`	`162`	`return nil, fmt.Errorf("read records failed: %v", errCode.String())`
`163`	`163`	`}`
`164`	`164`
`165`		`- var records []Record`
	`165`	`+ records := make([]Record, 0)`
`166`	`166`	`var getValue func(value []byte) (any, error)`
`167`	`167`	`switch {`
`168`	`168`	`case ct.Key() == "application/vnd.mokapi.kafka.binary+json":`