You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2023/11/15 10:47:41 UTC

(pulsar-client-go) branch master updated: [fix][TableView] Correct argument order to Errorf in TableView message handling(#1130)

This is an automated email from the ASF dual-hosted git repository.

zike pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new c91a800d [fix][TableView] Correct argument order to Errorf in TableView message handling(#1130)
c91a800d is described below

commit c91a800d3ac7dee1f00f33641895dd2ebf418311
Author: Oliver Muir <oj...@gmail.com>
AuthorDate: Wed Nov 15 10:47:36 2023 +0000

    [fix][TableView] Correct argument order to Errorf in TableView message handling(#1130)
    
    ### Motivation
    When TableView fails to read a message with the schema the error message is malformed, e.g.
    ```
    ERRO[0000] msg.GetSchemaValue() failed with %!w(*pulsar.message=&{[..snipped..]}); msg is schema not found for topic: [..snipped..], schema version : [ [0 0 0 0 0 0 0 0] ]
    ```
    
    The correct formatting will help users to debug their issues.
    
    
    ### Modifications
    
    Switch error args to match the formatting directives and context of the message.
    
    Signed-off-by: Oliver Muir <ol...@arenko.group>
    Co-authored-by: Oliver Muir <ol...@arenko.group>
---
 pulsar/table_view_impl.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar/table_view_impl.go b/pulsar/table_view_impl.go
index 85499f19..47f8c6c0 100644
--- a/pulsar/table_view_impl.go
+++ b/pulsar/table_view_impl.go
@@ -251,7 +251,7 @@ func (tv *TableViewImpl) handleMessage(msg Message) {
 	} else {
 		payload = reflect.Indirect(reflect.New(tv.options.SchemaValueType)).Interface()
 		if err := msg.GetSchemaValue(&payload); err != nil {
-			tv.logger.Errorf("msg.GetSchemaValue() failed with %w; msg is %v", msg, err)
+			tv.logger.Errorf("msg.GetSchemaValue() failed with %w; msg is %v", err, msg)
 		}
 		tv.data[msg.Key()] = payload
 	}