title: Spring Cloud Stream Supplier not producing messages to kafka enabled azure event hubs
body: <p>I am trying to send messages to kafka enabled azure event hubs applying features of spring cloud stream and spring cloud functions. The Supplier method is working fine when it is imperative. But i want the function to be triggered only one time. So, i tried to implement it on a reactive way but it is not sending any data. Can you please help me tweak it! Thank you!</p>
  <p>Sample code: Imperative:-</p>
  <p>@Bean
  public Supplier supply(){
  return () -&gt;{</p>
  <pre><code>    Student student= new Student(&quot;name&quot;,&quot;mark&quot;);
      LOGGER.info(&quot;{} {} for ${} for {}&quot;, student.getStatus());
  
      return student;
  
  };
  </code></pre>
  <p>}</p>
  <p>Reactive:</p>
  <pre><code>@Bean
  public Supplier&lt;Mono&lt;Student&gt;&gt; supply(){
   return () -&gt;{
  
      Student student= new Student(&quot;name&quot;,&quot;mark&quot;);
      LOGGER.info(&quot;{} {} for ${} for {}&quot;, student.getStatus());
  
      return Mono.just(student);
  
  };
  </code></pre>
  <h2>}</h2>
  <p>yaml file:
  spring:
  cloud:
  azure:
  eventhub:
  connection-string: [connectionsting]
  checkpoint-storage-account: [storageaccount]
  checkpoint-access-key:[accesskey]
  checkpoint-container: [container]</p>
  <pre><code>stream:
    function:
      definition: supply;consume
  
    bindings:
      supply-out-0:
        destination: [xx]
      consume-in-0:
        destination: [xx]
        group: $Default
  
    eventhub:
      bindings:
        consume-in-0:
          consumer:
            checkpoint-mode: Manual
  </code></pre>