springboot集成kafka实战项目，kafka生产者、消费者、创建topic，指定消费分区

[{"title":"（ 98 个子文件 109KB ） springboot集成kafka实战项目，kafka生产者、消费者、创建topic，指定消费分区","children":[{"title":"dume-springboot-kafka-server","children":[{"title":"mvnw.cmd <span style='color:#111;'> 6.45KB </span>","children":null,"spread":false},{"title":"dume-springboot-kafka-server.iml <span style='color:#111;'> 9.11KB </span>","children":null,"spread":false},{"title":"HELP.md <span style='color:#111;'> 1.05KB </span>","children":null,"spread":false},{"title":"mvnw <span style='color:#111;'> 9.83KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"example","children":[{"title":"dume","children":[{"title":"DumeSpringbootKafkaServerApplicationTests.java <span style='color:#111;'> 236B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"cmd","children":[{"title":"cmd.txt <span style='color:#111;'> 569B </span>","children":null,"spread":false}],"spread":true},{"title":"application.yml <span style='color:#111;'> 230B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"example","children":[{"title":"dume","children":[{"title":"controller","children":[{"title":"KafkaController.java <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false}],"spread":true},{"title":"DumeSpringbootKafkaServerApplication.java <span style='color:#111;'> 536B </span>","children":null,"spread":false},{"title":"config","children":[{"title":"KafkaProducerConfig.java <span style='color:#111;'> 3.31KB </span>","children":null,"spread":false},{"title":"KafkaTopicConfig.java <span style='color:#111;'> 1.38KB </span>","children":null,"spread":false},{"title":"KafkaConsumerConfig.java <span style='color:#111;'> 3.55KB </span>","children":null,"spread":false}],"spread":false},{"title":"manager","children":[{"title":"KafkaProducerManager.java <span style='color:#111;'> 1.75KB </span>","children":null,"spread":false},{"title":"KafkaComsumerManager.java <span style='color:#111;'> 2.51KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":"libraries","children":[{"title":"Maven__org_springframework_spring_tx_5_3_14.xml <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_jcl_5_3_14.xml <span style='color:#111;'> 560B </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__com_fasterxml_jackson_core_jackson_databind_2_13_1.xml <span style='color:#111;'> 630B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_13_1.xml <span style='color:#111;'> 736B </span>","children":null,"spread":false},{"title":"Maven__org_junit_jupiter_junit_jupiter_params_5_8_2.xml <span style='color:#111;'> 615B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_web_5_3_14.xml <span style='color:#111;'> 560B </span>","children":null,"spread":false},{"title":"Maven__com_github_luben_zstd_jni_1_5_0_2.xml <span style='color:#111;'> 541B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_context_5_3_14.xml <span style='color:#111;'> 588B </span>","children":null,"spread":false},{"title":"Maven__org_assertj_assertj_core_3_21_0.xml <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_autoconfigure_2_6_2.xml <span style='color:#111;'> 678B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jsr310_2_13_1.xml <span style='color:#111;'> 695B </span>","children":null,"spread":false},{"title":"Maven__javax_annotation_javax_annotation_api_1_3_2.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_mockito_mockito_core_4_0_0.xml <span style='color:#111;'> 535B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_webmvc_5_3_14.xml <span style='color:#111;'> 581B </span>","children":null,"spread":false},{"title":"Maven__org_opentest4j_opentest4j_1_2_0.xml <span style='color:#111;'> 533B </span>","children":null,"spread":false},{"title":"Maven__org_apache_logging_log4j_log4j_api_2_17_0.xml <span style='color:#111;'> 573B </span>","children":null,"spread":false},{"title":"Maven__jakarta_xml_bind_jakarta_xml_bind_api_2_3_3.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_logging_2_6_2.xml <span style='color:#111;'> 692B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_annotations_2_13_1.xml <span style='color:#111;'> 651B </span>","children":null,"spread":false},{"title":"Maven__org_junit_jupiter_junit_jupiter_api_5_8_2.xml <span style='color:#111;'> 594B </span>","children":null,"spread":false},{"title":"Maven__ch_qos_logback_logback_core_1_2_9.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jdk8_2_13_1.xml <span style='color:#111;'> 681B </span>","children":null,"spread":false},{"title":"Maven__net_minidev_accessors_smart_2_4_7.xml <span style='color:#111;'> 556B </span>","children":null,"spread":false},{"title":"Maven__org_xmlunit_xmlunit_core_2_8_4.xml <span style='color:#111;'> 535B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_core_9_0_56.xml <span style='color:#111;'> 625B </span>","children":null,"spread":false},{"title":"Maven__org_junit_jupiter_junit_jupiter_engine_5_8_2.xml <span style='color:#111;'> 615B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_messaging_5_3_14.xml <span style='color:#111;'> 602B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_retry_spring_retry_1_3_1.xml <span style='color:#111;'> 591B </span>","children":null,"spread":false},{"title":"Maven__org_objenesis_objenesis_3_2.xml <span style='color:#111;'> 508B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_aop_5_3_14.xml <span style='color:#111;'> 560B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_clients_3_0_0.xml <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_kafka_spring_kafka_2_8_1.xml <span style='color:#111;'> 591B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_websocket_9_0_56.xml <span style='color:#111;'> 660B </span>","children":null,"spread":false},{"title":"Maven__org_junit_platform_junit_platform_engine_1_8_2.xml <span style='color:#111;'> 626B </span>","children":null,"spread":false},{"title":"Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml <span style='color:#111;'> 700B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_jul_to_slf4j_1_7_32.xml <span style='color:#111;'> 534B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_api_1_7_32.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_2_6_2.xml <span style='color:#111;'> 580B </span>","children":null,"spread":false},{"title":"Maven__net_minidev_json_smart_2_4_7.xml <span style='color:#111;'> 521B </span>","children":null,"spread":false},{"title":"Maven__org_apiguardian_apiguardian_api_1_1_2.xml <span style='color:#111;'> 572B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_test_2_6_2.xml <span style='color:#111;'> 615B </span>","children":null,"spread":false},{"title":"Maven__com_alibaba_fastjson_1_2_49.xml <span style='color:#111;'> 514B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_tomcat_2_6_2.xml <span style='color:#111;'> 685B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_2_6_2.xml <span style='color:#111;'> 636B </span>","children":null,"spread":false},{"title":"Maven__org_junit_jupiter_junit_jupiter_5_8_2.xml <span style='color:#111;'> 566B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_json_2_6_2.xml <span style='color:#111;'> 671B </span>","children":null,"spread":false},{"title":"Maven__org_lz4_lz4_java_1_7_1.xml <span style='color:#111;'> 491B </span>","children":null,"spread":false},{"title":"Maven__com_google_code_findbugs_jsr305_3_0_2.xml <span style='color:#111;'> 545B </span>","children":null,"spread":false},{"title":"Maven__com_jayway_jsonpath_json_path_2_6_0.xml <span style='color:#111;'> 546B </span>","children":null,"spread":false},{"title":"Maven__org_yaml_snakeyaml_1_29.xml <span style='color:#111;'> 495B </span>","children":null,"spread":false},{"title":"Maven__org_hamcrest_hamcrest_2_2.xml <span style='color:#111;'> 497B </span>","children":null,"spread":false},{"title":"Maven__jakarta_activation_jakarta_activation_api_1_2_2.xml <span style='color:#111;'> 633B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_test_2_6_2.xml <span style='color:#111;'> 671B </span>","children":null,"spread":false},{"title":"Maven__net_bytebuddy_byte_buddy_agent_1_11_22.xml <span style='color:#111;'> 585B </span>","children":null,"spread":false},{"title":"Maven__ch_qos_logback_logback_classic_1_2_9.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_core_2_13_1.xml <span style='color:#111;'> 602B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_beans_5_3_14.xml <span style='color:#111;'> 574B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_6_2.xml <span style='color:#111;'> 713B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_expression_5_3_14.xml <span style='color:#111;'> 609B </span>","children":null,"spread":false},{"title":"Maven__org_skyscreamer_jsonassert_1_5_0.xml <span style='color:#111;'> 537B </span>","children":null,"spread":false},{"title":"Maven__org_ow2_asm_asm_9_1.xml <span style='color:#111;'> 458B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_el_9_0_56.xml <span style='color:#111;'> 611B </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__org_apache_logging_log4j_log4j_to_slf4j_2_17_0.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_test_5_3_14.xml <span style='color:#111;'> 567B </span>","children":null,"spread":false},{"title":"Maven__org_junit_platform_junit_platform_commons_1_8_2.xml <span style='color:#111;'> 633B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_web_2_6_2.xml <span style='color:#111;'> 664B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_core_5_3_14.xml <span style='color:#111;'> 567B </span>","children":null,"spread":false},{"title":"Maven__net_bytebuddy_byte_buddy_1_11_22.xml <span style='color:#111;'> 543B </span>","children":null,"spread":false},{"title":"Maven__org_mockito_mockito_junit_jupiter_4_0_0.xml <span style='color:#111;'> 598B </span>","children":null,"spread":false}],"spread":false},{"title":"misc.xml <span style='color:#111;'> 451B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 875B </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 4.14KB </span>","children":null,"spread":false},{"title":"$PRODUCT_WORKSPACE_FILE$ <span style='color:#111;'> 489B </span>","children":null,"spread":false},{"title":"sonarlint","children":[{"title":"issuestore","children":[{"title":"index.pb <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"encodings.xml <span style='color:#111;'> 177B </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":"modules.xml <span style='color:#111;'> 303B </span>","children":null,"spread":false}],"spread":true},{"title":".mvn","children":[{"title":"wrapper","children":[{"title":"MavenWrapperDownloader.java <span style='color:#111;'> 4.83KB </span>","children":null,"spread":false},{"title":"maven-wrapper.jar <span style='color:#111;'> 49.52KB </span>","children":null,"spread":false},{"title":"maven-wrapper.properties <span style='color:#111;'> 218B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false},{"title":".gitignore <span style='color:#111;'> 395B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]