Support Multiple Producer On the same Kafka Topic

[sshemirani]

The Producers should also include the "oneOf" in the "message" property of the generated Async api file.

Currently adding two producer on the same topic in the AsyncApiDocket configuration, results to one overriding the other and only the last one is included.

Here's the configuration that results in such an issue. You can see that the searchProducer and the retrieveProducer variables have the same topic.

@Bean
 public AsyncApiDocket asyncApiDocket(KafkaProperties kafkaProperties) {
        Info info = Info.builder()
                .version(asyncApiVersion)
                .title("Party Adapter Async API")
                .build();

        Server kafkaServer = Server.builder()
                .protocol("kafka")
                .url(String.join(",", kafkaProperties.getBootstrapServers()))
                .build();

        ProducerData searchProducer = ProducerData.builder()
                .channelName(replyTopic)
                .payloadType(PartySearchResultPayload.class)
                .binding(ImmutableMap.of("kafka", new KafkaOperationBinding()))
                .build();

        ProducerData retrieveProducer = ProducerData.builder()
                .channelName(replyTopic)
                .payloadType(PartyRetrieveResultPayload.class)
                .binding(ImmutableMap.of("kafka", new KafkaOperationBinding()))
                .build();

        return AsyncApiDocket.builder()
                .basePackage(BASE_PACKAGE_SCAN)
                .info(info)
                .producers(List.of(searchProducer, retrieveProducer))
                .server("kafka", kafkaServer)
                .build();
}

In the previous release you supported the @KafkaHandler that results in having "oneOf" property in the generated json. The producer also needs that.

Thank you

[stavshamir]

Makes a lot of sense and easy to implement. Thanks for the detailed example! I will add this to the next release.

[stavshamir]

Released in springwolf-kafka-0.5.0. Thanks for reporting this!