File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -523,11 +523,12 @@ public class KafkaTemplateTests {
523523 });
524524 container.setBeanName("templateTests");
525525 container.start();
526- ContainerTestUtils.waitForAssignment(container, embeddedKafka.getEmbeddedKafka().getPartitionsPerTopic());
527- Map<String, Object> senderProps =
528- KafkaTestUtils.senderProps(embeddedKafka.getEmbeddedKafka().getBrokersAsString());
526+ ContainerTestUtils.waitForAssignment(container,
527+ embeddedKafka.getEmbeddedKafka().getPartitionsPerTopic());
528+ Map<String, Object> producerProps =
529+ KafkaTestUtils.producerProps(embeddedKafka.getEmbeddedKafka());
529530 ProducerFactory<Integer, String> pf =
530- new DefaultKafkaProducerFactory<Integer, String>(senderProps );
531+ new DefaultKafkaProducerFactory<Integer, String>(producerProps );
531532 KafkaTemplate<Integer, String> template = new KafkaTemplate<>(pf);
532533 template.setDefaultTopic(TEMPLATE_TOPIC);
533534 template.sendDefault("foo");
You can’t perform that action at this time.
0 commit comments