title: Spring cloud stream Producer error handler not works
body: <p>I'm using spring cloud stream versione 3.1.4, and this is my producer</p>
  <pre><code>@Component
  public class Producer {    
      @Autowired
      private StreamBridge streamBridge;
  
      public void produce(int messageId, Object message) {
          Message&lt;Object&gt; msg= MessageBuilder
                  .withPayload(message)
                  .setHeader(&quot;partitionKey&quot;, messageId)
                  .build();
  
          streamBridge.send(&quot;outputchannel-out-0&quot;, msg);
      }
  
      @ServiceActivator(inputChannel = &quot;errorchannel.errors&quot;)
      public void errorHandler(ErrorMessage em) {
          log.info(&quot;Error: {}&quot;, em);
      }
  }
  </code></pre>
  <p>Into application.yaml I set errorChannelEnabled</p>
  <pre><code>spring:
    cloud:
      stream:
        bindings:
          #Channel name
          outputchannel-out-0:
            destination: my-topic
            contentType: application/json
            producer:
              partitionKeyExpression: headers['partitionKey']
              partitionCount: 1
              errorChannelEnabled: true
  </code></pre>
  <p>Now, If I change the <code>produce()</code> method in this way, in order to test the error handler</p>
  <pre><code>public void produce(int messageId, Object message) {
      throw new RuntimeException(&quot;Producer error&quot;);
  }
  </code></pre>
  <p>Nothing happens.
  Error handler is not triggered.
  I'm not sure that it's the right way to setup the error handler in spring cloud stream 3.1.4.</p>
  <p>Can you help me?</p>