From 112bef4f84de1ed1f68c610ee3f76c4cc3e2b13f Mon Sep 17 00:00:00 2001 From: alex-q-chen <79680040+alex-q-chen@users.noreply.github.com> Date: Wed, 3 Jul 2024 08:40:41 +0000 Subject: [PATCH] =?UTF-8?q?Deploying=20to=20gh-pages=20from=20@=20morganst?= =?UTF-8?q?anley/modern-cpp-kafka@15ee4332e3d8aadc18c695aa6de979ff30477325?= =?UTF-8?q?=20=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doxygen/AdminClientConfig_8h_source.html | 2 +- doxygen/AdminClient_8h_source.html | 2 +- doxygen/AdminCommon_8h_source.html | 2 +- doxygen/BrokerMetadata_8h_source.html | 2 +- doxygen/ClientCommon_8h_source.html | 2 +- doxygen/ClientConfig_8h_source.html | 2 +- doxygen/ConsumerCommon_8h_source.html | 2 +- doxygen/ConsumerConfig_8h_source.html | 2 +- doxygen/ConsumerRecord_8h_source.html | 2 +- doxygen/Error_8h_source.html | 2 +- doxygen/Header_8h_source.html | 2 +- doxygen/Interceptors_8h_source.html | 2 +- doxygen/KafkaClient_8h_source.html | 2 +- doxygen/KafkaConsumer_8h_source.html | 2 +- doxygen/KafkaException_8h_source.html | 2 +- doxygen/KafkaMetrics_8h_source.html | 373 +++++++++--------- doxygen/KafkaProducer_8h_source.html | 2 +- .../KafkaRecoverableProducer_8h_source.html | 2 +- doxygen/Log_8h_source.html | 10 +- doxygen/ProducerCommon_8h_source.html | 2 +- doxygen/ProducerConfig_8h_source.html | 2 +- doxygen/ProducerRecord_8h_source.html | 2 +- doxygen/Project_8h_source.html | 2 +- doxygen/Properties_8h_source.html | 2 +- doxygen/RdKafkaHelper_8h_source.html | 2 +- doxygen/Timestamp_8h_source.html | 2 +- doxygen/Types_8h_source.html | 2 +- .../UnorderedOffsetCommitQueue_8h_source.html | 2 +- doxygen/Utility_8h_source.html | 2 +- doxygen/annotated.html | 2 +- doxygen/classKAFKA__API_1_1Error-members.html | 2 +- doxygen/classKAFKA__API_1_1Error.html | 2 +- ...sKAFKA__API_1_1KafkaException-members.html | 2 +- .../classKAFKA__API_1_1KafkaException.html | 2 +- ...assKAFKA__API_1_1KafkaMetrics-members.html | 2 +- doxygen/classKAFKA__API_1_1KafkaMetrics.html | 2 +- ...classKAFKA__API_1_1Properties-members.html | 2 +- doxygen/classKAFKA__API_1_1Properties.html | 2 +- ...FKA__API_1_1clients_1_1Config-members.html | 2 +- .../classKAFKA__API_1_1clients_1_1Config.html | 2 +- ...PI_1_1clients_1_1Interceptors-members.html | 2 +- ...KAFKA__API_1_1clients_1_1Interceptors.html | 2 +- ...API_1_1clients_1_1KafkaClient-members.html | 2 +- ...sKAFKA__API_1_1clients_1_1KafkaClient.html | 2 +- ...ients_1_1admin_1_1AdminClient-members.html | 2 +- ...PI_1_1clients_1_1admin_1_1AdminClient.html | 2 +- ...1_1admin_1_1AdminClientConfig-members.html | 2 +- ...clients_1_1admin_1_1AdminClientConfig.html | 2 +- ...1_1consumer_1_1ConsumerConfig-members.html | 2 +- ...clients_1_1consumer_1_1ConsumerConfig.html | 2 +- ...umer_1_1ConsumerGroupMetadata-members.html | 2 +- ..._1_1consumer_1_1ConsumerGroupMetadata.html | 2 +- ...1_1consumer_1_1ConsumerRecord-members.html | 2 +- ...clients_1_1consumer_1_1ConsumerRecord.html | 2 +- ..._1_1consumer_1_1KafkaConsumer-members.html | 2 +- ...1clients_1_1consumer_1_1KafkaConsumer.html | 2 +- ...1_1UnorderedOffsetCommitQueue-members.html | 2 +- ...onsumer_1_1UnorderedOffsetCommitQueue.html | 2 +- ..._1_1producer_1_1KafkaProducer-members.html | 2 +- ...1clients_1_1producer_1_1KafkaProducer.html | 2 +- ...1_1producer_1_1ProducerConfig-members.html | 2 +- ...clients_1_1producer_1_1ProducerConfig.html | 2 +- ...1_1producer_1_1ProducerRecord-members.html | 2 +- ...clients_1_1producer_1_1ProducerRecord.html | 2 +- ...1_1producer_1_1RecordMetadata-members.html | 2 +- ...clients_1_1producer_1_1RecordMetadata.html | 2 +- doxygen/classes.html | 2 +- .../dir_4686ca24dd046c131774f5a6c51fabc1.html | 2 +- .../dir_66dec91c9059421677114a33862c20f7.html | 2 +- .../dir_d44c64559bbebec7f509842c48db8b23.html | 2 +- doxygen/files.html | 2 +- doxygen/functions.html | 2 +- doxygen/functions_enum.html | 2 +- doxygen/functions_func.html | 2 +- doxygen/functions_type.html | 2 +- doxygen/functions_vars.html | 2 +- doxygen/hierarchy.html | 2 +- doxygen/index.html | 2 +- ...tKAFKA__API_1_1BrokerMetadata-members.html | 2 +- .../structKAFKA__API_1_1BrokerMetadata.html | 2 +- ...API_1_1BrokerMetadata_1_1Node-members.html | 2 +- ...tKAFKA__API_1_1BrokerMetadata_1_1Node.html | 2 +- ...okerMetadata_1_1PartitionInfo-members.html | 2 +- ...PI_1_1BrokerMetadata_1_1PartitionInfo.html | 2 +- .../structKAFKA__API_1_1Header-members.html | 2 +- doxygen/structKAFKA__API_1_1Header.html | 2 +- ...structKAFKA__API_1_1Timestamp-members.html | 2 +- doxygen/structKAFKA__API_1_1Timestamp.html | 2 +- ...ients_1_1SaslOauthbearerToken-members.html | 2 +- ...PI_1_1clients_1_1SaslOauthbearerToken.html | 2 +- ..._1admin_1_1CreateTopicsResult-members.html | 2 +- ...lients_1_1admin_1_1CreateTopicsResult.html | 2 +- ...1admin_1_1DeleteRecordsResult-members.html | 2 +- ...ients_1_1admin_1_1DeleteRecordsResult.html | 2 +- ..._1admin_1_1DeleteTopicsResult-members.html | 2 +- ...lients_1_1admin_1_1DeleteTopicsResult.html | 2 +- ..._1_1admin_1_1ListTopicsResult-members.html | 2 +- ...1clients_1_1admin_1_1ListTopicsResult.html | 2 +- index.html | 4 +- markdown/KafkaBrokerConfiguration.html | 2 +- 100 files changed, 291 insertions(+), 290 deletions(-) diff --git a/doxygen/AdminClientConfig_8h_source.html b/doxygen/AdminClientConfig_8h_source.html index 68fba207..e4d22221 100644 --- a/doxygen/AdminClientConfig_8h_source.html +++ b/doxygen/AdminClientConfig_8h_source.html @@ -93,7 +93,7 @@ diff --git a/doxygen/AdminClient_8h_source.html b/doxygen/AdminClient_8h_source.html index 0379e16b..d0eca1de 100644 --- a/doxygen/AdminClient_8h_source.html +++ b/doxygen/AdminClient_8h_source.html @@ -417,7 +417,7 @@ diff --git a/doxygen/AdminCommon_8h_source.html b/doxygen/AdminCommon_8h_source.html index fe3ed1d3..4856b8c1 100644 --- a/doxygen/AdminCommon_8h_source.html +++ b/doxygen/AdminCommon_8h_source.html @@ -125,7 +125,7 @@ diff --git a/doxygen/BrokerMetadata_8h_source.html b/doxygen/BrokerMetadata_8h_source.html index 80d44ea7..c445fcfa 100644 --- a/doxygen/BrokerMetadata_8h_source.html +++ b/doxygen/BrokerMetadata_8h_source.html @@ -225,7 +225,7 @@ diff --git a/doxygen/ClientCommon_8h_source.html b/doxygen/ClientCommon_8h_source.html index facaa334..159dd757 100644 --- a/doxygen/ClientCommon_8h_source.html +++ b/doxygen/ClientCommon_8h_source.html @@ -104,7 +104,7 @@ diff --git a/doxygen/ClientConfig_8h_source.html b/doxygen/ClientConfig_8h_source.html index 203ccddb..6eb23f3e 100644 --- a/doxygen/ClientConfig_8h_source.html +++ b/doxygen/ClientConfig_8h_source.html @@ -165,7 +165,7 @@ diff --git a/doxygen/ConsumerCommon_8h_source.html b/doxygen/ConsumerCommon_8h_source.html index 3aa51568..65e0a01a 100644 --- a/doxygen/ConsumerCommon_8h_source.html +++ b/doxygen/ConsumerCommon_8h_source.html @@ -119,7 +119,7 @@ diff --git a/doxygen/ConsumerConfig_8h_source.html b/doxygen/ConsumerConfig_8h_source.html index 146acb62..079d1eb4 100644 --- a/doxygen/ConsumerConfig_8h_source.html +++ b/doxygen/ConsumerConfig_8h_source.html @@ -126,7 +126,7 @@ diff --git a/doxygen/ConsumerRecord_8h_source.html b/doxygen/ConsumerRecord_8h_source.html index 95644e95..d26b677a 100644 --- a/doxygen/ConsumerRecord_8h_source.html +++ b/doxygen/ConsumerRecord_8h_source.html @@ -199,7 +199,7 @@ diff --git a/doxygen/Error_8h_source.html b/doxygen/Error_8h_source.html index 7f405f22..4866beba 100644 --- a/doxygen/Error_8h_source.html +++ b/doxygen/Error_8h_source.html @@ -191,7 +191,7 @@ diff --git a/doxygen/Header_8h_source.html b/doxygen/Header_8h_source.html index 88f50370..43bc0f12 100644 --- a/doxygen/Header_8h_source.html +++ b/doxygen/Header_8h_source.html @@ -124,7 +124,7 @@ diff --git a/doxygen/Interceptors_8h_source.html b/doxygen/Interceptors_8h_source.html index 8b62ffb2..5b0b1122 100644 --- a/doxygen/Interceptors_8h_source.html +++ b/doxygen/Interceptors_8h_source.html @@ -125,7 +125,7 @@ diff --git a/doxygen/KafkaClient_8h_source.html b/doxygen/KafkaClient_8h_source.html index f8108135..8e82dbe5 100644 --- a/doxygen/KafkaClient_8h_source.html +++ b/doxygen/KafkaClient_8h_source.html @@ -822,7 +822,7 @@ diff --git a/doxygen/KafkaConsumer_8h_source.html b/doxygen/KafkaConsumer_8h_source.html index 19daa6fb..83b5f42d 100644 --- a/doxygen/KafkaConsumer_8h_source.html +++ b/doxygen/KafkaConsumer_8h_source.html @@ -1003,7 +1003,7 @@ diff --git a/doxygen/KafkaException_8h_source.html b/doxygen/KafkaException_8h_source.html index 1d690150..ff690317 100644 --- a/doxygen/KafkaException_8h_source.html +++ b/doxygen/KafkaException_8h_source.html @@ -127,7 +127,7 @@ diff --git a/doxygen/KafkaMetrics_8h_source.html b/doxygen/KafkaMetrics_8h_source.html index 6dbd38b3..ae393971 100644 --- a/doxygen/KafkaMetrics_8h_source.html +++ b/doxygen/KafkaMetrics_8h_source.html @@ -79,196 +79,197 @@
8 #include <rapidjson/writer.h>
9 
10 #include <algorithm>
-
11 #include <iostream>
-
12 #include <sstream>
-
13 #include <stdexcept>
-
14 #include <string>
-
15 #include <utility>
-
16 #include <vector>
-
17 
+
11 #include <cstdint>
+
12 #include <iostream>
+
13 #include <sstream>
+
14 #include <stdexcept>
+
15 #include <string>
+
16 #include <utility>
+
17 #include <vector>
18 
-
19 namespace KAFKA_API {
-
20 
-
24 class KafkaMetrics
-
25 {
-
26 public:
-
30  explicit KafkaMetrics(std::string jsonMetrics);
-
31 
-
32  static const constexpr char* WILDCARD = "*";
-
33 
-
34  using KeysType = std::vector<std::string>;
-
35 
-
39  template<typename ValueType>
-
40  using ResultsType = std::vector<std::pair<KeysType, ValueType>>;
-
41 
-
46  ResultsType<std::int64_t> getInt(const KeysType& keys) const { return get<std::int64_t>(keys); }
-
47 
-
52  ResultsType<std::string> getString(const KeysType& keys) const { return get<std::string>(keys); }
-
53 
-
54  static std::string toString(const KafkaMetrics::KeysType& keys);
-
55 
-
56  template<typename ValueType>
-
57  static std::string toString(const KafkaMetrics::ResultsType<ValueType>& results);
-
58 
-
59 private:
-
60  template<typename ValueType>
-
61  ResultsType<ValueType> get(const KeysType& keys) const;
-
62 
-
63  template<typename ValueType>
-
64  static void getResults(ResultsType<ValueType>& results,
-
65  KeysType& keysForWildcards,
-
66  rapidjson::Value::ConstMemberIterator iter,
-
67  KeysType::const_iterator keysToParse,
-
68  KeysType::const_iterator keysEnd);
-
69 
-
70  template<typename ValueType>
-
71  static ValueType getValue(rapidjson::Value::ConstMemberIterator iter);
-
72 
-
73 #if COMPILER_SUPPORTS_CPP_17
-
74  std::string _decodeBuf;
-
75 #else
-
76  std::vector<char> _decodeBuf;
-
77 #endif
-
78  rapidjson::Document _jsonDoc;
-
79 };
-
80 
-
81 inline
-
82 KafkaMetrics::KafkaMetrics(std::string jsonMetrics)
-
83 #if COMPILER_SUPPORTS_CPP_17
-
84  : _decodeBuf(std::move(jsonMetrics))
-
85 #else
-
86  : _decodeBuf(jsonMetrics.cbegin(), jsonMetrics.cend() + 1)
-
87 #endif
-
88 {
-
89  if (_jsonDoc.ParseInsitu(_decodeBuf.data()).HasParseError())
-
90  {
-
91  throw std::runtime_error("Failed to parse string with JSON format!");
-
92  }
-
93 }
-
94 
-
95 template<>
-
96 inline std::int64_t
-
97 KafkaMetrics::getValue<std::int64_t>(rapidjson::Value::ConstMemberIterator iter)
-
98 {
-
99  return iter->value.GetInt();
-
100 }
-
101 
-
102 template<>
-
103 inline std::string
-
104 KafkaMetrics::getValue<std::string>(rapidjson::Value::ConstMemberIterator iter)
-
105 {
-
106  return iter->value.GetString();
-
107 }
-
108 
-
109 template<typename ValueType>
-
110 inline KafkaMetrics::ResultsType<ValueType>
-
111 KafkaMetrics::get(const KeysType& keys) const
-
112 {
-
113  if (keys.empty()) throw std::invalid_argument("Input keys cannot be empty!");
-
114  if (keys.front() == WILDCARD) throw std::invalid_argument("The first key cannot be wildcard!");
-
115  if (keys.back() == WILDCARD) throw std::invalid_argument("The last key cannot be wildcard!");
-
116 
-
117  ResultsType<ValueType> results;
-
118 
-
119  const rapidjson::Value::ConstMemberIterator iter = _jsonDoc.FindMember(keys.front().c_str());
-
120  if (iter == _jsonDoc.MemberEnd()) return results;
-
121 
-
122  if (keys.size() == 1)
-
123  {
-
124  if (std::is_same<ValueType, std::string>::value ? iter->value.IsString() : iter->value.IsInt())
-
125  {
-
126  results.emplace_back(KeysType{}, getValue<ValueType>(iter));
-
127  }
-
128 
-
129  return results;
-
130  }
-
131 
-
132  KeysType keysForWildcards;
-
133 
-
134  getResults(results, keysForWildcards, iter, keys.cbegin() + 1, keys.cend());
-
135  return results;
-
136 }
-
137 
-
138 template<typename ValueType>
-
139 inline void
-
140 KafkaMetrics::getResults(KafkaMetrics::ResultsType<ValueType>& results,
-
141  KeysType& keysForWildcards,
-
142  rapidjson::Value::ConstMemberIterator iter,
-
143  KeysType::const_iterator keysToParse,
-
144  KeysType::const_iterator keysEnd)
-
145 {
-
146  if (!iter->value.IsObject()) return;
-
147 
-
148  const auto& key = *(keysToParse++);
-
149  const bool isTheEnd = (keysToParse == keysEnd);
-
150 
-
151  if (key == WILDCARD)
-
152  {
-
153  for (rapidjson::Value::ConstMemberIterator subIter = iter->value.MemberBegin(); subIter != iter->value.MemberEnd(); ++subIter)
-
154  {
-
155  KeysType newKeysForWildcards = keysForWildcards;
-
156  newKeysForWildcards.emplace_back(subIter->name.GetString());
-
157 
-
158  getResults(results, newKeysForWildcards, subIter, keysToParse, keysEnd);
-
159  }
-
160  }
-
161  else
-
162  {
-
163  const rapidjson::Value::ConstMemberIterator subIter = iter->value.FindMember(key.c_str());
-
164  if (subIter == iter->value.MemberEnd()) return;
-
165 
-
166  if (!isTheEnd)
-
167  {
-
168  getResults(results, keysForWildcards, subIter, keysToParse, keysEnd);
-
169  }
-
170  else if (std::is_same<ValueType, std::string>::value ? subIter->value.IsString() : subIter->value.IsInt())
-
171  {
-
172  results.emplace_back(keysForWildcards, getValue<ValueType>(subIter));
-
173  }
-
174  }
-
175 }
-
176 
-
177 inline std::string
-
178 KafkaMetrics::toString(const KafkaMetrics::KeysType& keys)
-
179 {
-
180  std::string ret;
-
181 
-
182  std::for_each(keys.cbegin(), keys.cend(),
-
183  [&ret](const auto& key){ ret.append((ret.empty() ? std::string() : std::string(", ")) + "\"" + key + "\""); });
-
184 
-
185  return ret;
-
186 }
-
187 
-
188 template<typename ValueType>
-
189 inline std::string
-
190 KafkaMetrics::toString(const KafkaMetrics::ResultsType<ValueType>& results)
-
191 {
-
192  std::ostringstream oss;
-
193  bool isTheFirstOne = true;
-
194 
-
195  std::for_each(results.cbegin(), results.cend(),
-
196  [&oss, &isTheFirstOne](const auto& result) {
-
197  const auto keysString = toString(result.first);
-
198 
-
199  oss << (isTheFirstOne ? (isTheFirstOne = false, "") : ", ")
-
200  << (keysString.empty() ? "" : (std::string("[") + keysString + "]:"));
-
201  oss << (std::is_same<ValueType, std::string>::value ? "\"" : "") << result.second << (std::is_same<ValueType, std::string>::value ? "\"" : "");
-
202  });
-
203 
-
204  return oss.str();
-
205 }
-
206 
-
207 } // end of KAFKA_API
-
208 
-
KAFKA_API::KafkaMetrics
Helps to parse the metrics string with JSON format.
Definition: KafkaMetrics.h:25
-
KAFKA_API::KafkaMetrics::getString
ResultsType< std::string > getString(const KeysType &keys) const
Get string value(s) for the specified metrics.
Definition: KafkaMetrics.h:52
-
KAFKA_API::KafkaMetrics::getInt
ResultsType< std::int64_t > getInt(const KeysType &keys) const
Get integer value(s) for the specified metrics.
Definition: KafkaMetrics.h:46
-
KAFKA_API::KafkaMetrics::KafkaMetrics
KafkaMetrics(std::string jsonMetrics)
Initilize with the metrics string.
Definition: KafkaMetrics.h:82
-
KAFKA_API::KafkaMetrics::ResultsType
std::vector< std::pair< KeysType, ValueType > > ResultsType
The matched keys (for wildcards) and the value.
Definition: KafkaMetrics.h:40
+
19 
+
20 namespace KAFKA_API {
+
21 
+
25 class KafkaMetrics
+
26 {
+
27 public:
+
31  explicit KafkaMetrics(std::string jsonMetrics);
+
32 
+
33  static const constexpr char* WILDCARD = "*";
+
34 
+
35  using KeysType = std::vector<std::string>;
+
36 
+
40  template<typename ValueType>
+
41  using ResultsType = std::vector<std::pair<KeysType, ValueType>>;
+
42 
+
47  ResultsType<std::int64_t> getInt(const KeysType& keys) const { return get<std::int64_t>(keys); }
+
48 
+
53  ResultsType<std::string> getString(const KeysType& keys) const { return get<std::string>(keys); }
+
54 
+
55  static std::string toString(const KafkaMetrics::KeysType& keys);
+
56 
+
57  template<typename ValueType>
+
58  static std::string toString(const KafkaMetrics::ResultsType<ValueType>& results);
+
59 
+
60 private:
+
61  template<typename ValueType>
+
62  ResultsType<ValueType> get(const KeysType& keys) const;
+
63 
+
64  template<typename ValueType>
+
65  static void getResults(ResultsType<ValueType>& results,
+
66  KeysType& keysForWildcards,
+
67  rapidjson::Value::ConstMemberIterator iter,
+
68  KeysType::const_iterator keysToParse,
+
69  KeysType::const_iterator keysEnd);
+
70 
+
71  template<typename ValueType>
+
72  static ValueType getValue(rapidjson::Value::ConstMemberIterator iter);
+
73 
+
74 #if COMPILER_SUPPORTS_CPP_17
+
75  std::string _decodeBuf;
+
76 #else
+
77  std::vector<char> _decodeBuf;
+
78 #endif
+
79  rapidjson::Document _jsonDoc;
+
80 };
+
81 
+
82 inline
+
83 KafkaMetrics::KafkaMetrics(std::string jsonMetrics)
+
84 #if COMPILER_SUPPORTS_CPP_17
+
85  : _decodeBuf(std::move(jsonMetrics))
+
86 #else
+
87  : _decodeBuf(jsonMetrics.cbegin(), jsonMetrics.cend() + 1)
+
88 #endif
+
89 {
+
90  if (_jsonDoc.ParseInsitu(_decodeBuf.data()).HasParseError())
+
91  {
+
92  throw std::runtime_error("Failed to parse string with JSON format!");
+
93  }
+
94 }
+
95 
+
96 template<>
+
97 inline std::int64_t
+
98 KafkaMetrics::getValue<std::int64_t>(rapidjson::Value::ConstMemberIterator iter)
+
99 {
+
100  return iter->value.GetInt();
+
101 }
+
102 
+
103 template<>
+
104 inline std::string
+
105 KafkaMetrics::getValue<std::string>(rapidjson::Value::ConstMemberIterator iter)
+
106 {
+
107  return iter->value.GetString();
+
108 }
+
109 
+
110 template<typename ValueType>
+
111 inline KafkaMetrics::ResultsType<ValueType>
+
112 KafkaMetrics::get(const KeysType& keys) const
+
113 {
+
114  if (keys.empty()) throw std::invalid_argument("Input keys cannot be empty!");
+
115  if (keys.front() == WILDCARD) throw std::invalid_argument("The first key cannot be wildcard!");
+
116  if (keys.back() == WILDCARD) throw std::invalid_argument("The last key cannot be wildcard!");
+
117 
+
118  ResultsType<ValueType> results;
+
119 
+
120  const rapidjson::Value::ConstMemberIterator iter = _jsonDoc.FindMember(keys.front().c_str());
+
121  if (iter == _jsonDoc.MemberEnd()) return results;
+
122 
+
123  if (keys.size() == 1)
+
124  {
+
125  if (std::is_same<ValueType, std::string>::value ? iter->value.IsString() : iter->value.IsInt())
+
126  {
+
127  results.emplace_back(KeysType{}, getValue<ValueType>(iter));
+
128  }
+
129 
+
130  return results;
+
131  }
+
132 
+
133  KeysType keysForWildcards;
+
134 
+
135  getResults(results, keysForWildcards, iter, keys.cbegin() + 1, keys.cend());
+
136  return results;
+
137 }
+
138 
+
139 template<typename ValueType>
+
140 inline void
+
141 KafkaMetrics::getResults(KafkaMetrics::ResultsType<ValueType>& results,
+
142  KeysType& keysForWildcards,
+
143  rapidjson::Value::ConstMemberIterator iter,
+
144  KeysType::const_iterator keysToParse,
+
145  KeysType::const_iterator keysEnd)
+
146 {
+
147  if (!iter->value.IsObject()) return;
+
148 
+
149  const auto& key = *(keysToParse++);
+
150  const bool isTheEnd = (keysToParse == keysEnd);
+
151 
+
152  if (key == WILDCARD)
+
153  {
+
154  for (rapidjson::Value::ConstMemberIterator subIter = iter->value.MemberBegin(); subIter != iter->value.MemberEnd(); ++subIter)
+
155  {
+
156  KeysType newKeysForWildcards = keysForWildcards;
+
157  newKeysForWildcards.emplace_back(subIter->name.GetString());
+
158 
+
159  getResults(results, newKeysForWildcards, subIter, keysToParse, keysEnd);
+
160  }
+
161  }
+
162  else
+
163  {
+
164  const rapidjson::Value::ConstMemberIterator subIter = iter->value.FindMember(key.c_str());
+
165  if (subIter == iter->value.MemberEnd()) return;
+
166 
+
167  if (!isTheEnd)
+
168  {
+
169  getResults(results, keysForWildcards, subIter, keysToParse, keysEnd);
+
170  }
+
171  else if (std::is_same<ValueType, std::string>::value ? subIter->value.IsString() : subIter->value.IsInt())
+
172  {
+
173  results.emplace_back(keysForWildcards, getValue<ValueType>(subIter));
+
174  }
+
175  }
+
176 }
+
177 
+
178 inline std::string
+
179 KafkaMetrics::toString(const KafkaMetrics::KeysType& keys)
+
180 {
+
181  std::string ret;
+
182 
+
183  std::for_each(keys.cbegin(), keys.cend(),
+
184  [&ret](const auto& key){ ret.append((ret.empty() ? std::string() : std::string(", ")) + "\"" + key + "\""); });
+
185 
+
186  return ret;
+
187 }
+
188 
+
189 template<typename ValueType>
+
190 inline std::string
+
191 KafkaMetrics::toString(const KafkaMetrics::ResultsType<ValueType>& results)
+
192 {
+
193  std::ostringstream oss;
+
194  bool isTheFirstOne = true;
+
195 
+
196  std::for_each(results.cbegin(), results.cend(),
+
197  [&oss, &isTheFirstOne](const auto& result) {
+
198  const auto keysString = toString(result.first);
+
199 
+
200  oss << (isTheFirstOne ? (isTheFirstOne = false, "") : ", ")
+
201  << (keysString.empty() ? "" : (std::string("[") + keysString + "]:"));
+
202  oss << (std::is_same<ValueType, std::string>::value ? "\"" : "") << result.second << (std::is_same<ValueType, std::string>::value ? "\"" : "");
+
203  });
+
204 
+
205  return oss.str();
+
206 }
+
207 
+
208 } // end of KAFKA_API
+
209 
+
KAFKA_API::KafkaMetrics
Helps to parse the metrics string with JSON format.
Definition: KafkaMetrics.h:26
+
KAFKA_API::KafkaMetrics::getString
ResultsType< std::string > getString(const KeysType &keys) const
Get string value(s) for the specified metrics.
Definition: KafkaMetrics.h:53
+
KAFKA_API::KafkaMetrics::getInt
ResultsType< std::int64_t > getInt(const KeysType &keys) const
Get integer value(s) for the specified metrics.
Definition: KafkaMetrics.h:47
+
KAFKA_API::KafkaMetrics::KafkaMetrics
KafkaMetrics(std::string jsonMetrics)
Initilize with the metrics string.
Definition: KafkaMetrics.h:83
+
KAFKA_API::KafkaMetrics::ResultsType
std::vector< std::pair< KeysType, ValueType > > ResultsType
The matched keys (for wildcards) and the value.
Definition: KafkaMetrics.h:41
diff --git a/doxygen/KafkaProducer_8h_source.html b/doxygen/KafkaProducer_8h_source.html index f6190d49..79e4d51f 100644 --- a/doxygen/KafkaProducer_8h_source.html +++ b/doxygen/KafkaProducer_8h_source.html @@ -513,7 +513,7 @@ diff --git a/doxygen/KafkaRecoverableProducer_8h_source.html b/doxygen/KafkaRecoverableProducer_8h_source.html index fbece968..b8fd8289 100644 --- a/doxygen/KafkaRecoverableProducer_8h_source.html +++ b/doxygen/KafkaRecoverableProducer_8h_source.html @@ -295,7 +295,7 @@ diff --git a/doxygen/Log_8h_source.html b/doxygen/Log_8h_source.html index 6c528043..1a2386ef 100644 --- a/doxygen/Log_8h_source.html +++ b/doxygen/Log_8h_source.html @@ -114,12 +114,12 @@
43 class LogBuffer
44 {
45 public:
-
46  LogBuffer():_wptr(_buf.data()) { _buf[0] = 0; } // NOLINT
+
46  LogBuffer() { clear(); }
47 
48  LogBuffer& clear()
49  {
-
50  _wptr = _buf.data();
-
51  _buf[0] = 0;
+
50  _buf[0] = 0;
+
51  _wptr = _buf.data();
52  return *this;
53  }
54 
@@ -143,7 +143,7 @@
72 
73 private:
74  std::array<char, MAX_CAPACITY> _buf;
-
75  char* _wptr;
+
75  char* _wptr = nullptr;
76 };
77 
78 
@@ -203,7 +203,7 @@ diff --git a/doxygen/ProducerCommon_8h_source.html b/doxygen/ProducerCommon_8h_source.html index d80e865f..7c02cdc4 100644 --- a/doxygen/ProducerCommon_8h_source.html +++ b/doxygen/ProducerCommon_8h_source.html @@ -240,7 +240,7 @@ diff --git a/doxygen/ProducerConfig_8h_source.html b/doxygen/ProducerConfig_8h_source.html index 5e451fba..4187d335 100644 --- a/doxygen/ProducerConfig_8h_source.html +++ b/doxygen/ProducerConfig_8h_source.html @@ -136,7 +136,7 @@ diff --git a/doxygen/ProducerRecord_8h_source.html b/doxygen/ProducerRecord_8h_source.html index 56d0de82..4aa5d729 100644 --- a/doxygen/ProducerRecord_8h_source.html +++ b/doxygen/ProducerRecord_8h_source.html @@ -154,7 +154,7 @@ diff --git a/doxygen/Project_8h_source.html b/doxygen/Project_8h_source.html index 987aa96b..e67c820d 100644 --- a/doxygen/Project_8h_source.html +++ b/doxygen/Project_8h_source.html @@ -91,7 +91,7 @@ diff --git a/doxygen/Properties_8h_source.html b/doxygen/Properties_8h_source.html index cae0d452..b7cb4b02 100644 --- a/doxygen/Properties_8h_source.html +++ b/doxygen/Properties_8h_source.html @@ -275,7 +275,7 @@ diff --git a/doxygen/RdKafkaHelper_8h_source.html b/doxygen/RdKafkaHelper_8h_source.html index 096f6791..bcdf2b42 100644 --- a/doxygen/RdKafkaHelper_8h_source.html +++ b/doxygen/RdKafkaHelper_8h_source.html @@ -212,7 +212,7 @@ diff --git a/doxygen/Timestamp_8h_source.html b/doxygen/Timestamp_8h_source.html index efd7c262..432ffb8e 100644 --- a/doxygen/Timestamp_8h_source.html +++ b/doxygen/Timestamp_8h_source.html @@ -156,7 +156,7 @@ diff --git a/doxygen/Types_8h_source.html b/doxygen/Types_8h_source.html index 7be6f528..b4698bb3 100644 --- a/doxygen/Types_8h_source.html +++ b/doxygen/Types_8h_source.html @@ -221,7 +221,7 @@ diff --git a/doxygen/UnorderedOffsetCommitQueue_8h_source.html b/doxygen/UnorderedOffsetCommitQueue_8h_source.html index 0140b626..38f4c06f 100644 --- a/doxygen/UnorderedOffsetCommitQueue_8h_source.html +++ b/doxygen/UnorderedOffsetCommitQueue_8h_source.html @@ -230,7 +230,7 @@ diff --git a/doxygen/Utility_8h_source.html b/doxygen/Utility_8h_source.html index 356d3682..4194e86d 100644 --- a/doxygen/Utility_8h_source.html +++ b/doxygen/Utility_8h_source.html @@ -139,7 +139,7 @@ diff --git a/doxygen/annotated.html b/doxygen/annotated.html index 83613edc..673c5c84 100644 --- a/doxygen/annotated.html +++ b/doxygen/annotated.html @@ -105,7 +105,7 @@ diff --git a/doxygen/classKAFKA__API_1_1Error-members.html b/doxygen/classKAFKA__API_1_1Error-members.html index 157ecea7..5bf62876 100644 --- a/doxygen/classKAFKA__API_1_1Error-members.html +++ b/doxygen/classKAFKA__API_1_1Error-members.html @@ -88,7 +88,7 @@ diff --git a/doxygen/classKAFKA__API_1_1Error.html b/doxygen/classKAFKA__API_1_1Error.html index cba3ade7..a8091798 100644 --- a/doxygen/classKAFKA__API_1_1Error.html +++ b/doxygen/classKAFKA__API_1_1Error.html @@ -200,7 +200,7 @@

diff --git a/doxygen/classKAFKA__API_1_1KafkaException-members.html b/doxygen/classKAFKA__API_1_1KafkaException-members.html index c5c3d48d..c7a9d61e 100644 --- a/doxygen/classKAFKA__API_1_1KafkaException-members.html +++ b/doxygen/classKAFKA__API_1_1KafkaException-members.html @@ -78,7 +78,7 @@ diff --git a/doxygen/classKAFKA__API_1_1KafkaException.html b/doxygen/classKAFKA__API_1_1KafkaException.html index 1eed6612..d58208a1 100644 --- a/doxygen/classKAFKA__API_1_1KafkaException.html +++ b/doxygen/classKAFKA__API_1_1KafkaException.html @@ -106,7 +106,7 @@ diff --git a/doxygen/classKAFKA__API_1_1KafkaMetrics-members.html b/doxygen/classKAFKA__API_1_1KafkaMetrics-members.html index 9f99f800..560c9904 100644 --- a/doxygen/classKAFKA__API_1_1KafkaMetrics-members.html +++ b/doxygen/classKAFKA__API_1_1KafkaMetrics-members.html @@ -83,7 +83,7 @@ diff --git a/doxygen/classKAFKA__API_1_1KafkaMetrics.html b/doxygen/classKAFKA__API_1_1KafkaMetrics.html index 9df261de..d152547a 100644 --- a/doxygen/classKAFKA__API_1_1KafkaMetrics.html +++ b/doxygen/classKAFKA__API_1_1KafkaMetrics.html @@ -188,7 +188,7 @@

diff --git a/doxygen/classKAFKA__API_1_1Properties-members.html b/doxygen/classKAFKA__API_1_1Properties-members.html index f3b3e985..97a05d15 100644 --- a/doxygen/classKAFKA__API_1_1Properties-members.html +++ b/doxygen/classKAFKA__API_1_1Properties-members.html @@ -89,7 +89,7 @@ diff --git a/doxygen/classKAFKA__API_1_1Properties.html b/doxygen/classKAFKA__API_1_1Properties.html index 9394e0bf..c979cd8a 100644 --- a/doxygen/classKAFKA__API_1_1Properties.html +++ b/doxygen/classKAFKA__API_1_1Properties.html @@ -221,7 +221,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1Config-members.html b/doxygen/classKAFKA__API_1_1clients_1_1Config-members.html index 689eddf6..d975986d 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1Config-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1Config-members.html @@ -116,7 +116,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1Config.html b/doxygen/classKAFKA__API_1_1clients_1_1Config.html index 739a36aa..297d4fff 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1Config.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1Config.html @@ -736,7 +736,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1Interceptors-members.html b/doxygen/classKAFKA__API_1_1clients_1_1Interceptors-members.html index d9045dd1..87263059 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1Interceptors-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1Interceptors-members.html @@ -85,7 +85,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1Interceptors.html b/doxygen/classKAFKA__API_1_1clients_1_1Interceptors.html index 2dc34eb2..675dcae6 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1Interceptors.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1Interceptors.html @@ -133,7 +133,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient-members.html b/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient-members.html index 539951b5..8801edb6 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient-members.html @@ -86,7 +86,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient.html b/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient.html index b0d9fa21..101f003e 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1KafkaClient.html @@ -214,7 +214,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient-members.html b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient-members.html index 06e56389..ebadfed9 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient-members.html @@ -91,7 +91,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient.html b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient.html index 0d9e3289..05444185 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClient.html @@ -204,7 +204,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig-members.html b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig-members.html index 65537423..2adcb94f 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig-members.html @@ -119,7 +119,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig.html b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig.html index cdb8d9a7..b5b7b2bf 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1admin_1_1AdminClientConfig.html @@ -237,7 +237,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig-members.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig-members.html index f8e7c276..12da6882 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig-members.html @@ -128,7 +128,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig.html index b6024b88..e92910a0 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerConfig.html @@ -445,7 +445,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata-members.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata-members.html index f2304018..063afb87 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata-members.html @@ -77,7 +77,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata.html index 98c0954c..973e1503 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerGroupMetadata.html @@ -95,7 +95,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord-members.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord-members.html index b70cb9d5..4ce41e1e 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord-members.html @@ -86,7 +86,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord.html index d937cc0e..32b31314 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1ConsumerRecord.html @@ -171,7 +171,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer-members.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer-members.html index 6f86e752..505dfb60 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer-members.html @@ -119,7 +119,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer.html index decfdc75..5fcfcc38 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1KafkaConsumer.html @@ -903,7 +903,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue-members.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue-members.html index d9717747..6215a4f3 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue-members.html @@ -82,7 +82,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue.html b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue.html index 7dc9264e..cb988315 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1consumer_1_1UnorderedOffsetCommitQueue.html @@ -175,7 +175,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer-members.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer-members.html index 2bf478b8..85f781e2 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer-members.html @@ -101,7 +101,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer.html index 52d63a20..af6ed0ad 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1KafkaProducer.html @@ -457,7 +457,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig-members.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig-members.html index 70d7c6ec..b1d066db 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig-members.html @@ -133,7 +133,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig.html index 4f515efe..b51c840c 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerConfig.html @@ -610,7 +610,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord-members.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord-members.html index cd22ab46..65a74bd4 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord-members.html @@ -92,7 +92,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord.html index 9b693ee7..0a55d10f 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1ProducerRecord.html @@ -184,7 +184,7 @@

diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata-members.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata-members.html index 41cf8945..f191f06d 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata-members.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata-members.html @@ -90,7 +90,7 @@ diff --git a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata.html b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata.html index 90405ff9..33b60a37 100644 --- a/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata.html +++ b/doxygen/classKAFKA__API_1_1clients_1_1producer_1_1RecordMetadata.html @@ -145,7 +145,7 @@ diff --git a/doxygen/classes.html b/doxygen/classes.html index 0d3a8347..609316cd 100644 --- a/doxygen/classes.html +++ b/doxygen/classes.html @@ -116,7 +116,7 @@ diff --git a/doxygen/dir_4686ca24dd046c131774f5a6c51fabc1.html b/doxygen/dir_4686ca24dd046c131774f5a6c51fabc1.html index f77dcf34..50436d2d 100644 --- a/doxygen/dir_4686ca24dd046c131774f5a6c51fabc1.html +++ b/doxygen/dir_4686ca24dd046c131774f5a6c51fabc1.html @@ -76,7 +76,7 @@ diff --git a/doxygen/dir_66dec91c9059421677114a33862c20f7.html b/doxygen/dir_66dec91c9059421677114a33862c20f7.html index f10ec8ff..7fef0f15 100644 --- a/doxygen/dir_66dec91c9059421677114a33862c20f7.html +++ b/doxygen/dir_66dec91c9059421677114a33862c20f7.html @@ -72,7 +72,7 @@ diff --git a/doxygen/dir_d44c64559bbebec7f509842c48db8b23.html b/doxygen/dir_d44c64559bbebec7f509842c48db8b23.html index 212d9ff4..3c5d1b08 100644 --- a/doxygen/dir_d44c64559bbebec7f509842c48db8b23.html +++ b/doxygen/dir_d44c64559bbebec7f509842c48db8b23.html @@ -76,7 +76,7 @@ diff --git a/doxygen/files.html b/doxygen/files.html index 3bf63561..4e49d2c9 100644 --- a/doxygen/files.html +++ b/doxygen/files.html @@ -104,7 +104,7 @@ diff --git a/doxygen/functions.html b/doxygen/functions.html index 3951755c..f7210ea6 100644 --- a/doxygen/functions.html +++ b/doxygen/functions.html @@ -642,7 +642,7 @@

- ~ -

    diff --git a/doxygen/functions_enum.html b/doxygen/functions_enum.html index 9868cfdf..2e17b423 100644 --- a/doxygen/functions_enum.html +++ b/doxygen/functions_enum.html @@ -72,7 +72,7 @@ diff --git a/doxygen/functions_func.html b/doxygen/functions_func.html index c24d9567..d86cb63e 100644 --- a/doxygen/functions_func.html +++ b/doxygen/functions_func.html @@ -453,7 +453,7 @@

    - ~ -

      diff --git a/doxygen/functions_type.html b/doxygen/functions_type.html index 0df39d17..d75d5d7f 100644 --- a/doxygen/functions_type.html +++ b/doxygen/functions_type.html @@ -78,7 +78,7 @@ diff --git a/doxygen/functions_vars.html b/doxygen/functions_vars.html index 6e3f0638..25ec320c 100644 --- a/doxygen/functions_vars.html +++ b/doxygen/functions_vars.html @@ -295,7 +295,7 @@

      - t -

        diff --git a/doxygen/hierarchy.html b/doxygen/hierarchy.html index 41d3fd01..ab508b79 100644 --- a/doxygen/hierarchy.html +++ b/doxygen/hierarchy.html @@ -101,7 +101,7 @@ diff --git a/doxygen/index.html b/doxygen/index.html index 74fd8fbb..d1970f36 100644 --- a/doxygen/index.html +++ b/doxygen/index.html @@ -68,7 +68,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata-members.html b/doxygen/structKAFKA__API_1_1BrokerMetadata-members.html index 5ffc3a04..85ab10bd 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata-members.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata-members.html @@ -85,7 +85,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata.html b/doxygen/structKAFKA__API_1_1BrokerMetadata.html index 304bf437..032ddc90 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata.html @@ -136,7 +136,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node-members.html b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node-members.html index cd9a3623..5f85bf96 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node-members.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node-members.html @@ -83,7 +83,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node.html b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node.html index 1af274b4..c64ca0fd 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1Node.html @@ -125,7 +125,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo-members.html b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo-members.html index 128dbf34..fadd1efd 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo-members.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo-members.html @@ -81,7 +81,7 @@ diff --git a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo.html b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo.html index 6291e419..ba8b1cb0 100644 --- a/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo.html +++ b/doxygen/structKAFKA__API_1_1BrokerMetadata_1_1PartitionInfo.html @@ -114,7 +114,7 @@ diff --git a/doxygen/structKAFKA__API_1_1Header-members.html b/doxygen/structKAFKA__API_1_1Header-members.html index 451995ff..f1256655 100644 --- a/doxygen/structKAFKA__API_1_1Header-members.html +++ b/doxygen/structKAFKA__API_1_1Header-members.html @@ -82,7 +82,7 @@ diff --git a/doxygen/structKAFKA__API_1_1Header.html b/doxygen/structKAFKA__API_1_1Header.html index 60d0a40b..09894d42 100644 --- a/doxygen/structKAFKA__API_1_1Header.html +++ b/doxygen/structKAFKA__API_1_1Header.html @@ -116,7 +116,7 @@ diff --git a/doxygen/structKAFKA__API_1_1Timestamp-members.html b/doxygen/structKAFKA__API_1_1Timestamp-members.html index ed3cba00..4c7e395e 100644 --- a/doxygen/structKAFKA__API_1_1Timestamp-members.html +++ b/doxygen/structKAFKA__API_1_1Timestamp-members.html @@ -86,7 +86,7 @@ diff --git a/doxygen/structKAFKA__API_1_1Timestamp.html b/doxygen/structKAFKA__API_1_1Timestamp.html index b6bea859..1f79e3e9 100644 --- a/doxygen/structKAFKA__API_1_1Timestamp.html +++ b/doxygen/structKAFKA__API_1_1Timestamp.html @@ -139,7 +139,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken-members.html b/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken-members.html index be39bede..6d133531 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken-members.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken-members.html @@ -80,7 +80,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken.html b/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken.html index 93828989..3a3c2303 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1SaslOauthbearerToken.html @@ -108,7 +108,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult-members.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult-members.html index 948adb6c..4563d9e8 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult-members.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult-members.html @@ -77,7 +77,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult.html index 34e22625..f7983fde 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1CreateTopicsResult.html @@ -100,7 +100,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult-members.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult-members.html index 44f76211..df87cc2c 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult-members.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult-members.html @@ -77,7 +77,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult.html index 4e2ab895..099f00a1 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteRecordsResult.html @@ -100,7 +100,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult-members.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult-members.html index 0b523d3e..00e3bffb 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult-members.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult-members.html @@ -77,7 +77,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult.html index b18926f2..c19a6062 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1DeleteTopicsResult.html @@ -100,7 +100,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult-members.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult-members.html index cf23c391..3312a97b 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult-members.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult-members.html @@ -79,7 +79,7 @@ diff --git a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult.html b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult.html index 9563b9c7..fdd9b37e 100644 --- a/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult.html +++ b/doxygen/structKAFKA__API_1_1clients_1_1admin_1_1ListTopicsResult.html @@ -107,7 +107,7 @@ diff --git a/index.html b/index.html index 66b73755..b4b3df5f 100644 --- a/index.html +++ b/index.html @@ -20,7 +20,7 @@

        Lifecycle Active

        The modern-cpp-kafka API is a layer of C++ wrapper based on librdkafka (the C part only), with high quality, but more friendly to users.

        KAFKA is a registered trademark of The Apache Software Foundation and
         
        @@ -1181,7 +1181,7 @@ 

        Run Tests


      - Generated: 2023. 04. 25 + Generated: 2024. 07. 03

      diff --git a/markdown/KafkaBrokerConfiguration.html b/markdown/KafkaBrokerConfiguration.html index df380228..a7f77ec4 100644 --- a/markdown/KafkaBrokerConfiguration.html +++ b/markdown/KafkaBrokerConfiguration.html @@ -264,7 +264,7 @@

      Performanc


    - Generated: 2023. 04. 25 + Generated: 2024. 07. 03