title: How Apache Kafka working with Spring boot application with OAuth
body: <p>This is producer</p>
  
  <pre><code>private void insertQueueEmail(EmailSendingRequestDTO emailSendingRequestDTO) {
      sender.kafkaSendEmail(emailSendingRequestDTO);
  }
  </code></pre>
  
  <p>This is consumer</p>
  
  <pre><code>  // @PreAuthorize("isAuthentication()")
    @KafkaListener(topics = "emailTopic", groupId = "foo")
    public ResponseEntity&lt;GECEorderResponseMessageDTO&gt; insertEmailQueue(@RequestBody 
           EmailSendingRequestDTO emailSendingRequestDTO) {
         ...... //do something
    }
  </code></pre>
  
  <p>Its work correctly, But when add @PreAuthorize("isAuthentication()") before @KafkaListener for validating access token I get 404 not found </p>
  
  <p>I need to know how can I using Kafka to send message to consumer and working with @PreAuthorize annotation</p>