Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Producer tries to Describe topics it has no access to #2063

Open
AnamikaN opened this issue Jun 3, 2020 · 0 comments
Open

Producer tries to Describe topics it has no access to #2063

AnamikaN opened this issue Jun 3, 2020 · 0 comments
Labels

Comments

@AnamikaN
Copy link

AnamikaN commented Jun 3, 2020

below is my code for producer. My producer is trying to access all the topics and then throwing error 'Denied Operation'. skyDriveProducer has access only to produce messages to qa.dcSacramento.skydrive. But it is trying to access other topics also and throwing error.

Any suggestions?

[2020-06-03 14:25:26,298] INFO Principal = User:skyDriveProducer is Denied Operation = Describe from host = 10.16.19.213 on resource = Topic:LITERAL:__consumer_offsets (kafka.authorizer.logger)
[2020-06-03 14:25:26,298] INFO Principal = User:skyDriveProducer is Denied Operation = Describe from host = 10.16.19.213 on resource = Topic:LITERAL:test (kafka.authorizer.logger)
[2020-06-03 14:25:26,298] INFO Principal = User:skyDriveProducer is Denied Operation = Describe from host = 10.16.19.213 on resource = Topic:LITERAL:qa.dcSacramento.skydrivetest (kafka.authorizer.logger)
[2020-06-03 14:25:26,298] INFO Principal = User:skyDriveProducer is Denied Operation = Describe from host = 10.16.19.213 on resource = Topic:LITERAL:__confluent.support.metrics (kafka.authorizer.logger)

`producer = KafkaProducer(bootstrap_servers=bootstrap_servers,
client_id=client_id,
security_protocol=security_protocol,
sasl_mechanism=sasl_mechanism,
sasl_plain_username=self.username,
sasl_plain_password=self.password,
ssl_check_hostname=False,
acks='all')

        for i in range(int(self.number_of_messages)):
            message = self.message_text + " Current time is " + get_pst_time()
            result = producer.send(self.topic, value=message).get()
            print("sending operation has completed - offset " + str(result.offset) + " topic " + str(result.topic)
                  + " partition " + str(result.partition))

        producer.close()`
@AnamikaN AnamikaN changed the title user is trying to access all topics Producer tries to Describe topics it has no access to Jun 3, 2020
@dpkp dpkp added the producer label Mar 18, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants