Linux内核源码/内存调优/文件系统/进程管理/设备驱动/网络协议栈零声
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());
