title: Spring cloud stream with reactive streams
body: <p><br/>
  my goal is to make an application using Spring cloud stream and Kafka, and discover the "reactive" world.
  I've something that works. Here is a part of my consumer.
  In my pom, i've declared : </p>
  
  <pre><code>        &lt;dependency&gt;
              &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
              &lt;artifactId&gt;spring-cloud-starter-stream-kafka&lt;/artifactId&gt;
          &lt;/dependency&gt;
  </code></pre>
  
  <p>That's 1.0.0.RELEASE that i use.<br/>
  I've declared my channels</p>
  
  <pre><code>public interface MyChannels {
  
      public static final String TOPIC_NAME = "myTopicName";
  
      @Input(TOPIC_NAME)
      MessageChannel receive();
  }
  </code></pre>
  
  <p>and then my service</p>
  
  <pre><code>@MessageEndpoint
  @EnableBinding(MyChannels.class)
  public class MyConsumer {
  
      @Autowired
      private MyChannels channels;
  
      @ServiceActivator(inputChannel=MyChannels.TOPIC_NAME)
      public void receive(MyObject object) {
          //apply my business logic
          //like save my object in a database
      }
  }
  </code></pre>
  
  <p>I receive my message well.
  I've seen in my dependencies that spring-integration-kafka depends on reactor-core.
  Is it sufficient to make my app "reactive" ?
  What should i do to apply the reactive programming style ?<br/></p>
  
  <p>Do i have to use the @EnableRxJavaProcessor, if yes, i don't understand how.</p>
  
  <p>If i'm not clear, don't hesitate to write it in comment. thanks</p>