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

akg17

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

TomF

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

akg17

  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

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

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.