Skip to content

Commit c9ba2bf

Browse files
committed
fix: update test command in local_testing/test.sh and improve header access in kafka_client
- Changed the test command in local_testing/test.sh to run 'make test' instead of 'make test_all' for more focused testing. - Updated the SendAndReceive method in kafka_client to use getter methods for ApiKey, ApiVersion, and CorrelationId, enhancing encapsulation and code clarity.
1 parent 791916c commit c9ba2bf

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

protocol/kafka_client/client.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,9 @@ func (c *Client) Close() error {
110110

111111
func (c *Client) SendAndReceive(request builder.RequestI, stageLogger *logger.Logger) (Response, error) {
112112
header := request.GetHeader()
113-
apiType := protocol.APIKeyToName(header.ApiKey)
114-
apiVersion := header.ApiVersion
115-
correlationId := header.CorrelationId
113+
apiType := protocol.APIKeyToName(header.GetApiKey())
114+
apiVersion := header.GetApiVersion()
115+
correlationId := header.GetCorrelationId()
116116
message := request.Encode()
117117

118118
stageLogger.Infof("Sending \"%s\" (version: %v) request (Correlation id: %v)", apiType, apiVersion, correlationId)

0 commit comments

Comments
 (0)