apache-kafka - オブジェクトを Kafka に送信するにはどうすればよいですか

Question

アプリケーションからテキスト メッセージを kafka に送信できませんが、オブジェクト (イベント) を送信しようとすると例外が発生します。

INFO: ErrorMessage [payload=org.springframework.messaging.MessageHandlingException: メッセージハンドラでエラーが発生しました [org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler#0]; ネストされた例外は java.lang.NullPointerException: in org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent null of org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent, headers={id=9068de1b- a1cc-c1b5-463a-107b7be21af4、タイムスタンプ = 1456754038408}] 1000

<int-kafka:producer-context id="kafkaProducerContext" producer-properties="producerProperties">
    <int-kafka:producer-configurations>

        <!-- Kafaka events topic -->
        <int-kafka:producer-configuration
                broker-list="localhost:9092"
                key-class-type="java.lang.String"
                key-encoder="kafkaReflectionEncoder"
                value-encoder="kafkaReflectionEncoder"
                value-class-type="org.springframework.data.mongodb.core.mapping.event.AfterSaveEvent"
                topic="eventsstream"
                compression-type="none"
        />

    </int-kafka:producer-configurations>
</int-kafka:producer-context>

 <bean id="kafkaReflectionEncoder" class="org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaEncoder">
    <constructor-arg value="java.lang.String" />
</bean>

どんな助けでも大歓迎です...