马老师kubernetes实战与源码剖析
@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());
props.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE_BETA);
props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 10000);
