Linux內(nèi)核源碼/內(nèi)存調(diào)優(yōu)/文件系統(tǒng)/進(jìn)程管理/設(shè)備驅(qū)動(dòng)/網(wǎng)絡(luò)協(xié)議棧零聲
private static final String SOURCE_TOPIC = "sourceTopic";
?private static final String SINK_TOPIC = "sinkTopic";
?@Test
?void helloWorld() {
? ?// kafka config
? ?Properties props = buildConfigProps();
? ?Serde<String> stringSerde = Serdes.String();
? ?props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, stringSerde.getClass().getName());
? ?props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, stringSerde.getClass().getName());
標(biāo)簽：
