擅长:python、mysql、java
<p>实际上有两种方法可以实现这一点:</p>
<pre><code>msg.value()['myFieldName']
</code></pre>
<p>或</p>
<pre><code>msg.value().get('myFieldName')
</code></pre>
<hr/>
<p>比如说,</p>
<pre><code>c = AvroConsumer({
'bootstrap.servers': 'localhost:9092',
'schema.registry.url': 'localhost:8081',
'group.id': 'test-group'
})
c.subscribe(['Topic'])
while True:
try:
msg = c.poll(10)
if msg:
print(f"field1 Value: {msg.value()['field1']}")
print(f"field2 Value: {msg.value().get('field2')}")
else:
pass
except SerializerError as e:
print(f"Message deserialization failed for message {msg}:\n{e}")
</code></pre>