馬老師多線程與高并發(fā)實(shí)戰(zhàn) mca架構(gòu)路線
kafka基礎(chǔ)配置
private static Properties buildConfigProps() {
? ?Properties props = new Properties();
? ?String applicationId = "test_33333";
? ?props.put("bootstrap.servers", "");
? ?props.put("application.id", applicationId);
? ?props.put("auto.commit.interval.ms", "1000");
? ?props.put("session.timeout.ms", "30000");
標(biāo)簽：
