我继承了Azure Event Hub作为管理和使用的资源。不幸的是,没有文件。我只能看到一个事件中心命名空间资源,并且有一个活动的事件中心实体。如果我点击它,只有一个$Default消费者组,我不能弄清楚事件中心做什么。是否可以查看事件中心的功能以及如何通过事件中心检索信息?
谢谢!
编辑:这是我正在使用的当前代码。我可以进行身份验证,但我没有收到任何消息,或者我无法检索Event Hub提供的内容。如何接收数据?
from confluent_kafka import Consumer, KafkaException, KafkaError
bootstrap_servers = SERVER
topic = TEST_HUB
group_id = ID
# Kafka Config
consumer_config = {
'bootstrap.servers': bootstrap_servers,
'group.id': group_id,
'auto.offset.reset': 'earliest',
'enable.auto.commit': False,
'security.protocol': 'SASL_SSL',
'sasl.mechanism': 'PLAIN',
'sasl.username': '$ConnectionString',
'sasl.password': MY_EVENT_HUB_ENDPOINT
}
# Consumer
consumer = Consumer(consumer_config)
# Subscribe to the azure event hub
consumer.subscribe([topic])
# Consume messages from Kafka
try:
while True:
message = consumer.poll(5.0)
if message is None:
continue
if message.error():
if message.error().code() == KafkaError._PARTITION_EOF:
# End of partition event
continue
else:
# Handle error
print(f"Error: {message.error().str()}")
break
# Process the Kafka message
key = message.key()
value = message.value()
print(value)
# Commit the message offset
consumer.commit(message)
except KeyboardInterrupt:
pass
finally:
# Close
consumer.close()
1条答案
按热度按时间k5ifujac1#
事件中心向任何希望阅读事件的消费者公开事件。详情请参阅:Azure Event Hub和refer1、refer2
希望能帮上忙。