Skip to content

Commit 87d95be

Browse files
authored
Update KafkaMessage.h
1 parent f8262f8 commit 87d95be

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/protocol/KafkaMessage.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ class KafkaMessage : public ProtocolMessage
6060
void set_api_version(int ver) { this->api_version = ver; }
6161
int get_api_version() const { return this->api_version; }
6262

63-
void set_correlation_id(int id) { this-> correlation_id = id; }
63+
void set_correlation_id(int id) { this->correlation_id = id; }
6464
int get_correlation_id() const { return this->correlation_id; }
6565

6666
void set_config(const KafkaConfig& conf)

0 commit comments

Comments
 (0)