Update KafkaMessage.h

This commit is contained in:
xiehan
2022-11-01 17:51:05 +08:00
committed by GitHub
parent f8262f877b
commit 87d95beaef
+1 -1
View File
@@ -60,7 +60,7 @@ public:
void set_api_version(int ver) { this->api_version = ver; }
int get_api_version() const { return this->api_version; }
void set_correlation_id(int id) { this-> correlation_id = id; }
void set_correlation_id(int id) { this->correlation_id = id; }
int get_correlation_id() const { return this->correlation_id; }
void set_config(const KafkaConfig& conf)