python kafka权限校验client.id

Posted huim

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python kafka权限校验client.id相关的知识,希望对你有一定的参考价值。

kafka集群有权限校验,在连接时需要加入client.id。但pykafka不能配置该选项。搜索了一下,需要使用confluent-kafka

链接: https://blog.csdn.net/lanyang123456/article/details/80639625

#coding:utf-8

from confluent_kafka import Consumer, KafkaError

mybroker = "127.0.0.1:9092"  #host
client_id = "校验id"
my_topic = "你的topic"

c = Consumer({
    'bootstrap.servers': mybroker,
    'group.id': 'mygroup',
    'client.id': client_id ,
    'default.topic.config': {
    'auto.offset.reset': 'smallest'
    }
})

c.subscribe([my_topic])

while True:
    msg = c.poll(1.0)

    if msg is None:
        continue
    if msg.error():
        if msg.error().code() == KafkaError._PARTITION_EOF:
            continue
        else:
            print(msg.error())
            break

    print('Received message: {}'.format(msg.value().decode('utf-8')))

c.close()

以上是关于python kafka权限校验client.id的主要内容,如果未能解决你的问题,请参考以下文章

drf 权限校验设置与源码分析

kafka权限

9. SpringCloud之权限校验方案

SpringCloud---zuul权限校验接口限流

SpringCloud----zuul权限校验接口限流

权限校验过滤器