title: How to read from the end of a topic, regardless of the group's committed offset
body: <p>I am using following packages to consume kafka messages </p>
  
  <pre><code>compile 'org.springframework.boot:spring-boot-starter-webflux'
  compile("org.springframework.boot:spring-boot-starter-web")
  // tag::actuator[]
  compile("org.springframework.boot:spring-boot-starter-actuator")
  compile('org.springframework.kafka:spring-kafka:2.1.7.RELEASE')
  compile 'io.projectreactor.kafka:reactor-kafka:1.0.0.RELEASE'
  </code></pre>
  
  <p>I want to consume messages from the end of a topic, regardless of the group's committed offset</p>
  
  <p>When I search I found we can do using following code  </p>
  
  <pre><code>consumer = new KafkaConsumer&lt;&gt;(properties);
  consumer.seekToEnd(Collections.emptySet());
  </code></pre>
  
  <p>But I am unable to find how to use above code in spring boot webflux </p>
  
  <pre><code>@Component
  public class EventConsumer
  {
      private final EmitterProcessor&lt;ServerSentEvent&lt;String&gt;&gt; emitter = EmitterProcessor.create();
  
      public Flux&lt;ServerSentEvent&lt;String&gt;&gt; get()
      {
          return emitter;
      }
  
      @KafkaListener(topics = "${kafka.zone.status.topic.name}")
      public void receive(String data)
      {
          //System.out.println(data);
          emitter.onNext(ServerSentEvent.builder(data).id(UUID.randomUUID().toString()).build());
      }
  }
  </code></pre>