马老师多线程与高并发实战 mca架构路线
kafka基础配置
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");
