kafka学习代码（java开发kafka）

[{"title":"（ 94 个子文件 87KB ） kafka学习代码（java开发kafka）","children":[{"title":"kafka-study","children":[{"title":".gitignore <span style='color:#111;'> 395B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 23B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"wlx","children":[{"title":"kafka","children":[{"title":"KafkaStudyApplication.java <span style='color:#111;'> 326B </span>","children":null,"spread":false},{"title":"thread","children":[{"title":"plan2","children":[{"title":"ConsumerThreadPoolOther.java <span style='color:#111;'> 3.67KB </span>","children":null,"spread":false}],"spread":true},{"title":"plan1","children":[{"title":"ConsumerThreadPoolTypical.java <span style='color:#111;'> 3.54KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"admin","children":[{"title":"AdminSample.java <span style='color:#111;'> 6.01KB </span>","children":null,"spread":false}],"spread":true},{"title":"producer","children":[{"title":"PartitionSample.java <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"ProducerSample.java <span style='color:#111;'> 11.33KB </span>","children":null,"spread":false}],"spread":true},{"title":"spring","children":[{"title":"KafkaProducerClient.java <span style='color:#111;'> 1.31KB </span>","children":null,"spread":false}],"spread":true},{"title":"common","children":[{"title":"Constants.java <span style='color:#111;'> 341B </span>","children":null,"spread":false}],"spread":false},{"title":"interceptor","children":[{"title":"ProducerInterceptorSample.java <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":"ConsumerInterceptorSample.java <span style='color:#111;'> 1.02KB </span>","children":null,"spread":false}],"spread":false},{"title":"cusumer","children":[{"title":"ConsumerSample.java <span style='color:#111;'> 13.20KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.54KB </span>","children":null,"spread":false},{"title":"client.truststore.jks <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 0B </span>","children":null,"spread":false},{"title":"target","children":[{"title":"classes","children":[{"title":"com","children":[{"title":"wlx","children":[{"title":"kafka","children":[{"title":"KafkaStudyApplication.class <span style='color:#111;'> 745B </span>","children":null,"spread":false},{"title":"thread","children":[{"title":"plan2","children":[{"title":"ConsumerThreadPoolOther$ConsumerExecutor.class <span style='color:#111;'> 3.97KB </span>","children":null,"spread":false},{"title":"ConsumerThreadPoolOther.class <span style='color:#111;'> 1.18KB </span>","children":null,"spread":false},{"title":"ConsumerThreadPoolOther$ConsumerRunnable.class <span style='color:#111;'> 1.76KB </span>","children":null,"spread":false}],"spread":true},{"title":"plan1","children":[{"title":"ConsumerThreadPoolTypical$KafkaConsumerRunner.class <span style='color:#111;'> 4.37KB </span>","children":null,"spread":false},{"title":"ConsumerThreadPoolTypical.class <span style='color:#111;'> 1.05KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"admin","children":[{"title":"AdminSample.class <span style='color:#111;'> 9.34KB </span>","children":null,"spread":false}],"spread":true},{"title":"producer","children":[{"title":"ProducerSample$3.class <span style='color:#111;'> 1.35KB </span>","children":null,"spread":false},{"title":"ProducerSample.class <span style='color:#111;'> 6.10KB </span>","children":null,"spread":false},{"title":"ProducerSample$2.class <span style='color:#111;'> 1.33KB </span>","children":null,"spread":false},{"title":"PartitionSample.class <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false},{"title":"ProducerSample$1.class <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false}],"spread":false},{"title":"spring","children":[{"title":"KafkaProducerClient.class <span style='color:#111;'> 1.43KB </span>","children":null,"spread":false}],"spread":false},{"title":"common","children":[{"title":"Constants.class <span style='color:#111;'> 267B </span>","children":null,"spread":false}],"spread":false},{"title":"interceptor","children":[{"title":"ProducerInterceptorSample.class <span style='color:#111;'> 1.67KB </span>","children":null,"spread":false},{"title":"ConsumerInterceptorSample.class <span style='color:#111;'> 1.25KB </span>","children":null,"spread":false}],"spread":false},{"title":"cusumer","children":[{"title":"ConsumerSample.class <span style='color:#111;'> 7.66KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"application.yml <span style='color:#111;'> 21B </span>","children":null,"spread":false}],"spread":true},{"title":"generated-sources","children":[{"title":"annotations","children":null,"spread":false}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":".gitignore <span style='color:#111;'> 242B </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 380B </span>","children":null,"spread":false},{"title":"encodings.xml <span style='color:#111;'> 191B </span>","children":null,"spread":false},{"title":"libraries","children":[{"title":"Maven__org_lz4_lz4_java_1_7_1.xml <span style='color:#111;'> 491B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_el_9_0_46.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_xerial_snappy_snappy_java_1_1_8_1.xml <span style='color:#111;'> 566B </span>","children":null,"spread":false},{"title":"Maven__ch_qos_logback_logback_core_1_2_3.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_annotations_2_12_3.xml <span style='color:#111;'> 651B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_aop_5_3_7.xml <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_2_5_0.xml <span style='color:#111;'> 636B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_autoconfigure_2_5_0.xml <span style='color:#111;'> 678B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_json_2_5_0.xml <span style='color:#111;'> 671B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_websocket_9_0_46.xml <span style='color:#111;'> 660B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_core_2_12_3.xml <span style='color:#111;'> 602B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_logging_2_5_0.xml <span style='color:#111;'> 692B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_2_5_0.xml <span style='color:#111;'> 580B </span>","children":null,"spread":false},{"title":"Maven__jakarta_annotation_jakarta_annotation_api_1_3_5.xml <span style='color:#111;'> 633B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jsr310_2_12_3.xml <span style='color:#111;'> 695B </span>","children":null,"spread":false},{"title":"Maven__com_github_luben_zstd_jni_1_4_9_1.xml <span style='color:#111;'> 541B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_context_5_3_7.xml <span style='color:#111;'> 581B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_core_9_0_46.xml <span style='color:#111;'> 625B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_beans_5_3_7.xml <span style='color:#111;'> 567B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_tomcat_2_5_0.xml <span style='color:#111;'> 685B </span>","children":null,"spread":false},{"title":"Maven__org_apache_logging_log4j_log4j_api_2_14_1.xml <span style='color:#111;'> 573B </span>","children":null,"spread":false},{"title":"Maven__ch_qos_logback_logback_classic_1_2_3.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_webmvc_5_3_7.xml <span style='color:#111;'> 574B </span>","children":null,"spread":false},{"title":"Maven__org_apache_logging_log4j_log4j_to_slf4j_2_14_1.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_12_3.xml <span style='color:#111;'> 736B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_jcl_5_3_7.xml <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jdk8_2_12_3.xml <span style='color:#111;'> 681B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_api_1_7_30.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_expression_5_3_7.xml <span style='color:#111;'> 602B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_web_5_3_7.xml <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_web_2_5_0.xml <span style='color:#111;'> 664B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_clients_2_8_0.xml <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"Maven__org_yaml_snakeyaml_1_28.xml <span style='color:#111;'> 495B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_databind_2_12_3.xml <span style='color:#111;'> 630B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_core_5_3_7.xml <span style='color:#111;'> 560B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_jul_to_slf4j_1_7_30.xml <span style='color:#111;'> 534B </span>","children":null,"spread":false}],"spread":false},{"title":"workspace.xml <span style='color:#111;'> 13.03KB </span>","children":null,"spread":false},{"title":"uiDesigner.xml <span style='color:#111;'> 8.71KB </span>","children":null,"spread":false},{"title":"inspectionProfiles","children":[{"title":"Project_Default.xml <span style='color:#111;'> 1.41KB </span>","children":null,"spread":false}],"spread":true},{"title":"sonarlint","children":[{"title":"issuestore","children":[{"title":"9","children":[{"title":"0","children":[{"title":"90ade7238ec67a8204a075b680f49d027967f317 <span style='color:#111;'> 559B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"4","children":[{"title":"4","children":[{"title":"442292b8a7efeabbe4cc176709b833b1792140ec <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":false},{"title":"6","children":[{"title":"46371c1dec1074f52079f4c2f187af96266f026c <span style='color:#111;'> 253B </span>","children":null,"spread":false}],"spread":false},{"title":"b","children":null,"spread":false}],"spread":false},{"title":"6","children":[{"title":"3","children":[{"title":"63c8d969219a510aaaa4b1be66b89d3cf5f5fa9b <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false}],"spread":false},{"title":"7","children":[{"title":"674b5dbd77d1f776522e1d3b8576c2b381e81f41 <span style='color:#111;'> 493B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"3","children":[{"title":"7","children":[{"title":"3776181fb94860e9a4ad1cafbd9cbcfd255d04ed <span style='color:#111;'> 2.27KB </span>","children":null,"spread":false}],"spread":false},{"title":"1","children":null,"spread":false}],"spread":false},{"title":"d","children":[{"title":"6","children":[{"title":"d610af2e9fb18b548a626358673415cdaee77783 <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":false},{"title":"b","children":[{"title":"db002b96095941851f6fe89746a914844b6ca593 <span style='color:#111;'> 2.53KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"8","children":[{"title":"f","children":[{"title":"8fe93d2d379e9ed2266a30770384438cc5ff5bb2 <span style='color:#111;'> 4.23KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"7","children":[{"title":"9","children":null,"spread":false}],"spread":false},{"title":"2","children":[{"title":"5","children":[{"title":"25dd99635ca39ee23f0df05757836f19425e3c53 <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"f","children":[{"title":"4","children":[{"title":"f4608d9082c726a3a44aa0caeb57975723429486 <span style='color:#111;'> 204B </span>","children":null,"spread":false}],"spread":false},{"title":"6","children":[{"title":"f6faae1168dc2f9797e0b067db025972f54a4ec3 <span style='color:#111;'> 797B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"b","children":[{"title":"8","children":null,"spread":false}],"spread":false},{"title":"1","children":[{"title":"6","children":[{"title":"16b3386920f3f6a29fbd8572de68b418ad0d4f5f <span style='color:#111;'> 91B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"index.pb <span style='color:#111;'> 1.31KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"compiler.xml <span style='color:#111;'> 824B </span>","children":null,"spread":false},{"title":"jarRepositories.xml <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false},{"title":"modules.xml <span style='color:#111;'> 269B </span>","children":null,"spread":false}],"spread":false},{"title":"kafka-study.iml <span style='color:#111;'> 4.84KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]