`@EmbeddedKafkaRule` to `@EmbeddedKafka` test conversion · Issue #75 · openrewrite/rewrite-spring

link管理

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

安静的土豆 · 云数据库Tair连接器使用方法及参数）_实时 ...· 20 小时前 ·

逼格高的蛋挞 · Java 将 Char 转换为 Int 实例· 7 小时前 ·

不要命的鸡蛋 · List (或ArrayList) ...· 7 小时前 ·

多情的伏特加 · C++ String(字符串)和 ...· 7 小时前 ·

独立的电影票 · java如何随机生成颜色代码 | ...· 2 小时前 ·

憨厚的打火机 · 白嫖党福音，艾编程arry老师博客三十天免费 ...· 10 月前 ·

风流倜傥的帽子 · 解决IDEA报错：Caused by: ...· 1 年前 ·

绅士的机器人 · LEXUS雷克萨斯官网· 1 年前 ·

拉风的汉堡包 · 不只在澀谷！拜訪【八公】的故鄉及秋田縣大館市 ...· 1 年前 ·

神勇威武的茶壶 · 游戏行业有哪些职位(游戏行业哪些职位工资高) ...· 1 年前 ·

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement . We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

@EmbeddedKafkaRule to @EmbeddedKafka for JUnit 5 tests migration recipe.

https://docs.spring.io/spring-kafka/docs/current/api/org/springframework/kafka/test/context/EmbeddedKafka.html
https://blog.mimacom.com/testing-apache-kafka-with-spring-boot-junit5/


   @EmbeddedKafka


   @ExtendWith(SpringExtension.class)


   @TestInstance(TestInstance.Lifecycle.PER_CLASS)


   @Autowired


   private EmbeddedKafkaBroker embeddedKafkaBroker;

remove static modifier from setup() method (note.


    @TestInstance

annotation).

replace


    embeddedKafka.getEmbeddedKafka()

with


    embeddedKafkaBroker

before:

public class KafkaItemReaderTests {
	@ClassRule
	public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1);
	private KafkaItemReader<String, String> reader;
	private KafkaTemplate<String, String> template;
	private Properties consumerProperties;
	@BeforeClass
	public static void setUpTopics() {
		embeddedKafka.getEmbeddedKafka().addTopics(
				new NewTopic("topic1", 1, (short) 1),
				new NewTopic("topic2", 2, (short) 1),
				new NewTopic("topic3", 1, (short) 1),
				new NewTopic("topic4", 2, (short) 1),
				new NewTopic("topic5", 1, (short) 1),
				new NewTopic("topic6", 1, (short) 1)
	@Before
	public void setUp() {
		Map<String, Object> producerProperties = KafkaTestUtils.producerProps(embeddedKafka.getEmbeddedKafka());
		ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(producerProperties);
		this.template = new KafkaTemplate<>(producerFactory);
		this.consumerProperties = new Properties();
		this.consumerProperties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
				embeddedKafka.getEmbeddedKafka().getBrokersAsString());
		this.consumerProperties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, "1");
		this.consumerProperties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
				StringDeserializer.class.getName());
		this.consumerProperties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
				StringDeserializer.class.getName());
after:
@EmbeddedKafka
@ExtendWith(SpringExtension.class)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class KafkaItemReaderTests {
	@Autowired
	private EmbeddedKafkaBroker embeddedKafkaBroker;
	private KafkaItemReader<String, String> reader;
	private KafkaTemplate<String, String> template;
	private Properties consumerProperties;
	@BeforeAll
	public void setUpTopics() {
		embeddedKafkaBroker.addTopics(
				new NewTopic("topic1", 1, (short) 1),
				new NewTopic("topic2", 2, (short) 1),
				new NewTopic("topic3", 1, (short) 1),
				new NewTopic("topic4", 2, (short) 1),
				new NewTopic("topic5", 1, (short) 1),
				new NewTopic("topic6", 1, (short) 1)
	@BeforeEach
	public void setUp() {
		Map<String, Object> producerProperties = KafkaTestUtils.producerProps(embeddedKafkaBroker);
		ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(producerProperties);
		this.template = new KafkaTemplate<>(producerFactory);
		this.consumerProperties = new Properties();
		this.consumerProperties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
				embeddedKafkaBroker.getBrokersAsString());
		this.consumerProperties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, "1");
		this.consumerProperties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
				StringDeserializer.class.getName());
		this.consumerProperties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
				StringDeserializer.class.getName());