403: Subscription ACL Denied - Queue 'scst/wk/txGroup/plain/txError' - Topic 'txError'

akg17
akg17 Member Posts: 76
edited May 2021 in General Discussions #1

Config - application.yml

spring:
  cloud:
    stream:
      default:
       group: txGroup
       contentType: application/json
       consumer:
         concurrency: 2
         maxAttempts: 1
      bindings:
        output:
          consumer:
            group: txGroup
            provisionDurableQueue: true
            autoBindErrorQueue: true
            errorQueueNameOverride: txError
            durableSubscription: true
            republishToDlq: true

=====================================================

    @StreamListener(LoanProcessor.TX_ERROR)
    public void txError(Message message) {

        System.out.println("ERROR :: " + message.toString());
    }

==================================================

  String TX_ERROR = "txError";
  @Input(TX_ERROR)
  SubscribableChannel errors();

====================================================

@EnableBinding(LoanProcessor.class)
@SpringBootApplication
public class LoanCheckApplication {

  public static final Logger log = LoggerFactory.getLogger(LoanCheckApplication.class);

  public static void main(String[] args) {
    SpringApplication.run(LoanCheckApplication.class, args);
    log.info("The Loancheck Application has started...");
  }
}

provided the code and the ACL access denied, basically i tried to create autobind error queue to one of my consumer but except for this all are working why error queue is not working

Comments

  • TomF
    TomF Member, Employee Posts: 412 Solace Employee

    Could you post the ACL profile, @akg17? You'll probably find subscriptions are not allowed except a certain list.

  • akg17
    akg17 Member Posts: 76
      solace:
        bindings:
          output:
            consumer:
              group: txGroup
              provisionDurableQueue: true
              autoBindErrorQueue: true
              errorQueueNameOverride: txError
              durableSubscription: true
    

    With this configuration if exception thrown from the output listener then message is republished to txError queue and i see those messages queued but when i subcsibed to them its creating a new queue with scst/wk/txGroup/plain/txError
    and yesterday i was getting acl denied but FYI everything is default action - allow, acl profile is default with no exemptions

  • Tamimi
    Tamimi Member, Administrator, Employee Posts: 538 admin
    edited May 2021 #4

    Hey @akg17 - a quick tip for formatting your code in the post, I have edited your original post by adding ``` in your post between the code blocks for easier readability when you post your question. I hope this helps!

  • tejaschowsalkar
    tejaschowsalkar Member Posts: 13

    Could you please check your ACL profile associated for that particular user you may have subscribe topic as disabled or may be you need add an exception for your use case.