@@ -117,15 +117,16 @@ class ErrorImpl : public Error {
117
117
public:
118
118
~ErrorImpl () {
119
119
rd_kafka_error_destroy (c_error_);
120
- };
120
+ }
121
121
122
122
ErrorImpl (ErrorCode code, const std::string *errstr) {
123
123
c_error_ = rd_kafka_error_new (static_cast <rd_kafka_resp_err_t >(code),
124
124
errstr ? " %s" : NULL ,
125
125
errstr ? errstr->c_str () : NULL );
126
126
}
127
127
128
- ErrorImpl (rd_kafka_error_t *c_error) : c_error_(c_error) {};
128
+ ErrorImpl (rd_kafka_error_t *c_error) : c_error_(c_error) {
129
+ }
129
130
130
131
static Error *create (ErrorCode code, const std::string *errstr) {
131
132
return new ErrorImpl (code, errstr);
@@ -161,7 +162,8 @@ class ErrorImpl : public Error {
161
162
162
163
class EventImpl : public Event {
163
164
public:
164
- ~EventImpl () {};
165
+ ~EventImpl () {
166
+ }
165
167
166
168
EventImpl (Type type,
167
169
ErrorCode err,
@@ -175,7 +177,8 @@ class EventImpl : public Event {
175
177
str_ (str),
176
178
id_ (0 ),
177
179
throttle_time_ (0 ),
178
- fatal_ (false ) {};
180
+ fatal_ (false ) {
181
+ }
179
182
180
183
EventImpl (Type type) :
181
184
type_ (type),
@@ -185,7 +188,8 @@ class EventImpl : public Event {
185
188
str_ (" " ),
186
189
id_ (0 ),
187
190
throttle_time_ (0 ),
188
- fatal_ (false ) {};
191
+ fatal_ (false ) {
192
+ }
189
193
190
194
Type type () const {
191
195
return type_;
@@ -379,7 +383,7 @@ class MessageImpl : public Message {
379
383
delete key_;
380
384
if (headers_)
381
385
delete headers_;
382
- };
386
+ }
383
387
384
388
MessageImpl (rd_kafka_type_t rk_type,
385
389
RdKafka::Topic *topic,
@@ -495,7 +499,7 @@ class MessageImpl : public Message {
495
499
496
500
void *msg_opaque () const {
497
501
return rkmessage_->_private ;
498
- };
502
+ }
499
503
500
504
int64_t latency () const {
501
505
return rd_kafka_message_latency (rkmessage_);
@@ -990,11 +994,13 @@ class ConfImpl : public Conf {
990
994
991
995
class HandleImpl : virtual public Handle {
992
996
public:
993
- ~HandleImpl () {};
994
- HandleImpl () {};
997
+ ~HandleImpl () {
998
+ }
999
+ HandleImpl () {
1000
+ }
995
1001
std::string name () const {
996
1002
return std::string (rd_kafka_name (rk_));
997
- };
1003
+ }
998
1004
std::string memberid () const {
999
1005
char *str = rd_kafka_memberid (rk_);
1000
1006
std::string memberid = str ? str : " " ;
@@ -1004,10 +1010,10 @@ class HandleImpl : virtual public Handle {
1004
1010
}
1005
1011
int poll (int timeout_ms) {
1006
1012
return rd_kafka_poll (rk_, timeout_ms);
1007
- };
1013
+ }
1008
1014
int outq_len () {
1009
1015
return rd_kafka_outq_len (rk_);
1010
- };
1016
+ }
1011
1017
1012
1018
void set_common_config (const RdKafka::ConfImpl *confimpl);
1013
1019
@@ -1127,7 +1133,7 @@ class HandleImpl : virtual public Handle {
1127
1133
ErrorCode oauthbearer_set_token_failure (const std::string &errstr) {
1128
1134
return static_cast <ErrorCode>(
1129
1135
rd_kafka_oauthbearer_set_token_failure (rk_, errstr.c_str ()));
1130
- };
1136
+ }
1131
1137
1132
1138
Error *sasl_background_callbacks_enable () {
1133
1139
rd_kafka_error_t *c_error = rd_kafka_sasl_background_callbacks_enable (rk_);
@@ -1140,11 +1146,11 @@ class HandleImpl : virtual public Handle {
1140
1146
1141
1147
void *mem_malloc (size_t size) {
1142
1148
return rd_kafka_mem_malloc (rk_, size);
1143
- };
1149
+ }
1144
1150
1145
1151
void mem_free (void *ptr) {
1146
1152
rd_kafka_mem_free (rk_, ptr);
1147
- };
1153
+ }
1148
1154
1149
1155
rd_kafka_t *rk_;
1150
1156
/* All Producer and Consumer callbacks must reside in HandleImpl and
@@ -1201,7 +1207,8 @@ class TopicImpl : public Topic {
1201
1207
*/
1202
1208
class TopicPartitionImpl : public TopicPartition {
1203
1209
public:
1204
- ~TopicPartitionImpl () {};
1210
+ ~TopicPartitionImpl () {
1211
+ }
1205
1212
1206
1213
static TopicPartition *create (const std::string &topic, int partition);
1207
1214
@@ -1371,7 +1378,7 @@ class KafkaConsumerImpl : virtual public KafkaConsumer,
1371
1378
1372
1379
bool closed () {
1373
1380
return rd_kafka_consumer_closed (rk_) ? true : false ;
1374
- };
1381
+ }
1375
1382
1376
1383
ErrorCode seek (const TopicPartition &partition, int timeout_ms);
1377
1384
@@ -1420,7 +1427,7 @@ class ConsumerImpl : virtual public Consumer, virtual public HandleImpl {
1420
1427
~ConsumerImpl () {
1421
1428
if (rk_)
1422
1429
rd_kafka_destroy (rk_);
1423
- };
1430
+ }
1424
1431
static Consumer *create (Conf *conf, std::string &errstr);
1425
1432
1426
1433
ErrorCode start (Topic *topic, int32_t partition, int64_t offset);
@@ -1453,7 +1460,7 @@ class ProducerImpl : virtual public Producer, virtual public HandleImpl {
1453
1460
~ProducerImpl () {
1454
1461
if (rk_)
1455
1462
rd_kafka_destroy (rk_);
1456
- };
1463
+ }
1457
1464
1458
1465
ErrorCode produce (Topic *topic,
1459
1466
int32_t partition,
0 commit comments