+ @Bean
+ KafkaTemplate<String, String> kafkaTemplate(EmbeddedKafkaBroker embeddedKafka)
+ {
+ Map<String, Object> producerProps = KafkaTestUtils.producerProps(embeddedKafka);
+ ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(producerProps);
+ return new KafkaTemplate<>(producerFactory);
+ }
+
+ @Bean
+ Producer<String, AbstractMessageTo> chatRoomChannelProducer(
+ StringSerializer stringSerializer,
+ JsonSerializer<AbstractMessageTo> messageSerializer)
+ {
+ Map<String, Object> properties = new HashMap<>();
+ properties.put(
+ ProducerConfig.CLIENT_ID_CONFIG,
+ "KAFKACHATHOMETEST_CHATROOM_CHANNEL_PRODUCER");
+ return new KafkaProducer<>(
+ properties,
+ stringSerializer,
+ messageSerializer);
+ }
+