We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 13eeedf + 31d0071 commit 076227fCopy full SHA for 076227f
ncdssdk_client/src/main/python/ncdsclient/NCDSSession.py
@@ -133,7 +133,7 @@ def cont_stream_cmd(self):
133
if message is None:
134
print(f"No Records Found for the Topic: {self.topic}")
135
else:
136
- print(f"value :" + message.value())
+ print(f"value :" + str(message.value()))
137
consumer.commit(message=message, asynchronous=True)
138
139
except KafkaException as e:
@@ -179,7 +179,7 @@ def filter_stream_cmd(self):
179
f"{symbol}, msg_name: {msg_name}")
180
if (not self.symbols or symbol in symbol_set) and (
181
not self.msgnames or msg_name in msgname_set):
182
- print(message.value())
+ print(str(message.value()))
183
184
except KeyError:
185
pass
0 commit comments