title: Spring Cloud Bus event ( RemoteApplicationEvent ) not being published to Kafka
body: <p>I am using spring cloud bus to publish event to kafka so that another instance can listen the same event . Event is being triggered but not being published to kafka . 
  I am using spring cloud bus with spring cloud stream . </p>
  
  <p>version :
  Spring Boot : 2.0,
  Spring cloud Bus : 2.0.0,
  Spring Cloud Stream : 2.0.1</p>
  
  <p>application.yml :</p>
  
  <pre><code>server:
    port: 7711
  spring:
    application:
      index: ${random.uuid}
    cloud:
      bus:
        enabled: true
      stream:
        kafka:
          binder:
            brokers: localhost:9092
        bindings:
          input:
            destination: EMPLOYEE-TOPIC-DEMO-R1-P1
            group: ali
  </code></pre>
  
  <p>pom.xml </p>
  
  <pre><code>&lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-stream&lt;/artifactId&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-stream-binder-kafka&lt;/artifactId&gt;
  &lt;/dependency&gt;
  
  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-starter-bus-kafka&lt;/artifactId&gt;
  &lt;/dependency&gt;
  </code></pre>
  
  <p>Publishing Event :</p>
  
  <pre><code>@Autowired
  private ApplicationContext context;
  
  @StreamListener(ConsumerStream.INPUT)
  public void messageConsumer(@Payload String jsonValue, @Headers MessageHeaders header) {
  
      try {
          log.info("Enter in Consumer-&gt;messageConsumer()");
          final String myUniqueId = context.getId();
          context.publishEvent(new MessagingEventBus(this,myUniqueId,header));
      } catch (Exception e) {
          log.error("Exception caught while processing the request :", e);
      }
  }
  </code></pre>
  
  <p>Event Class :</p>
  
  <pre><code>@Slf4j
  public class MessagingEventBus extends RemoteApplicationEvent {
  
  
      private MessageHeaders header;
  
      // Must supply a default constructor and getters/setters for deserialization
      public MessagingEventBus() {
      }
  
      public MessagingEventBus(Object source, String originService, MessageHeaders header) {
          // source is the object that is publishing the event
          // originService is the unique context ID of the publisher
          super(source, originService);
          this.header = header;
      }
  
  
  }
  </code></pre>
  
  <p>Event Listener :</p>
  
  <pre><code>@Component
  @Slf4j
  public class MessagingEventBusListener implements ApplicationListener&lt;MessagingEventBus&gt; {
  
      @Override
      public void onApplicationEvent(MessagingEventBus messagingEventBus) {
         log.info("Messaging Event Bus Listener called");
      }
  }
  </code></pre>