Spring cloud stream with reactive streams
<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>