kafka监听样例.rar

上传者: u010782875 | 上传时间: 2021-09-10 15:59:56 | 文件大小: 49KB | 文件类型: RAR
springboot框架中kafka生产者和消费者的配置说明,包括kafka依赖、配置类、自定义消息体、处理类和测试类

文件下载

资源详情

[{"title":"( 95 个子文件 49KB ) kafka监听样例.rar","children":[{"title":"kafka监听样例","children":[{"title":"KafkaSimpleExample-master","children":[{"title":"pom.xml <span style='color:#111;'> 2.51KB </span>","children":null,"spread":false},{"title":"target","children":[{"title":"generated-sources","children":[{"title":"annotations","children":null,"spread":false}],"spread":true},{"title":"classes","children":[{"title":"com","children":[{"title":"imooc","children":[{"title":"kafka","children":[{"title":"consumer","children":[{"title":"SimpleConsumer.class <span style='color:#111;'> 1.19KB </span>","children":null,"spread":false}],"spread":true},{"title":"ExamplesApplication.class <span style='color:#111;'> 743B </span>","children":null,"spread":false},{"title":"producer","children":[{"title":"SimpleProducer.class <span style='color:#111;'> 2.46KB </span>","children":null,"spread":false},{"title":"ProducerCallback.class <span style='color:#111;'> 3.15KB </span>","children":null,"spread":false}],"spread":true},{"title":"controller","children":[{"title":"ProduceController.class <span style='color:#111;'> 2.50KB </span>","children":null,"spread":false}],"spread":true},{"title":"common","children":[{"title":"Response.class <span style='color:#111;'> 868B </span>","children":null,"spread":false},{"title":"ErrorCode.class <span style='color:#111;'> 382B </span>","children":null,"spread":false},{"title":"MessageEntity.class <span style='color:#111;'> 1.88KB </span>","children":null,"spread":false}],"spread":true},{"title":"config","children":[{"title":"KafkaProducerConfig.class <span style='color:#111;'> 2.74KB </span>","children":null,"spread":false},{"title":"KafkaConsumerConfig.class <span style='color:#111;'> 3.70KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"application.properties <span style='color:#111;'> 1.33KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 1.94KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"imooc","children":[{"title":"kafka","children":[{"title":"consumer","children":[{"title":"SimpleConsumer.java <span style='color:#111;'> 607B </span>","children":null,"spread":false}],"spread":true},{"title":"producer","children":[{"title":"ProducerCallback.java <span style='color:#111;'> 1.72KB </span>","children":null,"spread":false},{"title":"SimpleProducer.java <span style='color:#111;'> 1.20KB </span>","children":null,"spread":false}],"spread":true},{"title":"ExamplesApplication.java <span style='color:#111;'> 409B </span>","children":null,"spread":false},{"title":"controller","children":[{"title":"ProduceController.java <span style='color:#111;'> 1.67KB </span>","children":null,"spread":false}],"spread":false},{"title":"common","children":[{"title":"ErrorCode.java <span style='color:#111;'> 148B </span>","children":null,"spread":false},{"title":"MessageEntity.java <span style='color:#111;'> 421B </span>","children":null,"spread":false},{"title":"Response.java <span style='color:#111;'> 283B </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"KafkaConsumerConfig.java <span style='color:#111;'> 2.91KB </span>","children":null,"spread":false},{"title":"KafkaProducerConfig.java <span style='color:#111;'> 2.22KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"examples.iml <span style='color:#111;'> 8.19KB </span>","children":null,"spread":false},{"title":".idea","children":[{"title":"$PRODUCT_WORKSPACE_FILE$ <span style='color:#111;'> 489B </span>","children":null,"spread":false},{"title":"libraries","children":[{"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_springframework_boot_spring_boot_2_0_3_RELEASE.xml <span style='color:#111;'> 636B </span>","children":null,"spread":false},{"title":"Maven__org_hamcrest_hamcrest_core_1_3.xml <span style='color:#111;'> 532B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_kafka_spring_kafka_2_1_7_RELEASE.xml <span style='color:#111;'> 647B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_core_8_5_31.xml <span style='color:#111;'> 625B </span>","children":null,"spread":false},{"title":"Maven__net_minidev_accessors_smart_1_2.xml <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"Maven__javax_validation_validation_api_2_0_1_Final.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__net_minidev_json_smart_2_3.xml <span style='color:#111;'> 507B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_annotations_2_9_0.xml <span style='color:#111;'> 644B </span>","children":null,"spread":false},{"title":"Maven__com_google_code_gson_gson_2_8_5.xml <span style='color:#111;'> 515B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_jcl_5_0_7_RELEASE.xml <span style='color:#111;'> 609B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_test_5_0_7_RELEASE.xml <span style='color:#111;'> 616B </span>","children":null,"spread":false},{"title":"Maven__org_jboss_logging_jboss_logging_3_3_2_Final.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__org_hibernate_validator_hibernate_validator_6_0_10_Final.xml <span style='color:#111;'> 681B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_web_5_0_7_RELEASE.xml <span style='color:#111;'> 609B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_test_2_0_3_RELEASE.xml <span style='color:#111;'> 671B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_classmate_1_3_4.xml <span style='color:#111;'> 522B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_autoconfigure_2_0_3_RELEASE.xml <span style='color:#111;'> 734B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_2_0_3_RELEASE.xml <span style='color:#111;'> 692B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_clients_1_0_1.xml <span style='color:#111;'> 562B </span>","children":null,"spread":false},{"title":"Maven__org_ow2_asm_asm_5_0_4.xml <span style='color:#111;'> 472B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_core_5_0_7_RELEASE.xml <span style='color:#111;'> 616B </span>","children":null,"spread":false},{"title":"Maven__org_hamcrest_hamcrest_library_1_3.xml <span style='color:#111;'> 553B </span>","children":null,"spread":false},{"title":"Maven__org_xerial_snappy_snappy_java_1_1_4.xml <span style='color:#111;'> 552B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_9_6.xml <span style='color:#111;'> 729B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_0_3_RELEASE.xml <span style='color:#111;'> 769B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_context_5_0_7_RELEASE.xml <span style='color:#111;'> 637B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_databind_2_9_0.xml <span style='color:#111;'> 623B </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__org_springframework_spring_aop_5_0_7_RELEASE.xml <span style='color:#111;'> 609B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_expression_5_0_7_RELEASE.xml <span style='color:#111;'> 658B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_core_2_9_6.xml <span style='color:#111;'> 595B </span>","children":null,"spread":false},{"title":"Maven__org_objenesis_objenesis_2_6.xml <span style='color:#111;'> 508B </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__com_jayway_jsonpath_json_path_2_4_0.xml <span style='color:#111;'> 546B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_tomcat_2_0_3_RELEASE.xml <span style='color:#111;'> 741B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_websocket_8_5_31.xml <span style='color:#111;'> 660B </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_springframework_boot_spring_boot_starter_web_2_0_3_RELEASE.xml <span style='color:#111;'> 720B </span>","children":null,"spread":false},{"title":"Maven__junit_junit_4_12.xml <span style='color:#111;'> 455B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_beans_5_0_7_RELEASE.xml <span style='color:#111;'> 623B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_jul_to_slf4j_1_7_25.xml <span style='color:#111;'> 534B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_api_1_7_25.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"Maven__org_apache_logging_log4j_log4j_to_slf4j_2_10_0.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__org_assertj_assertj_core_3_9_1.xml <span style='color:#111;'> 535B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_json_2_0_3_RELEASE.xml <span style='color:#111;'> 727B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jdk8_2_9_6.xml <span style='color:#111;'> 674B </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_springframework_boot_spring_boot_starter_logging_2_0_3_RELEASE.xml <span style='color:#111;'> 748B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_webmvc_5_0_7_RELEASE.xml <span style='color:#111;'> 630B </span>","children":null,"spread":false},{"title":"Maven__net_bytebuddy_byte_buddy_agent_1_7_11.xml <span style='color:#111;'> 578B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_retry_spring_retry_1_2_2_RELEASE.xml <span style='color:#111;'> 647B </span>","children":null,"spread":false},{"title":"Maven__org_xmlunit_xmlunit_core_2_5_1.xml <span style='color:#111;'> 535B </span>","children":null,"spread":false},{"title":"Maven__org_mockito_mockito_core_2_15_0.xml <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"Maven__org_lz4_lz4_java_1_4.xml <span style='color:#111;'> 477B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_messaging_5_0_7_RELEASE.xml <span style='color:#111;'> 651B </span>","children":null,"spread":false},{"title":"Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_31.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__javax_servlet_javax_servlet_api_3_1_0.xml <span style='color:#111;'> 578B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_datatype_jackson_datatype_jsr310_2_9_6.xml <span style='color:#111;'> 688B </span>","children":null,"spread":false},{"title":"Maven__org_projectlombok_lombok_1_16_22.xml <span style='color:#111;'> 531B </span>","children":null,"spread":false},{"title":"Maven__net_bytebuddy_byte_buddy_1_7_11.xml <span style='color:#111;'> 536B </span>","children":null,"spread":false},{"title":"Maven__org_yaml_snakeyaml_1_19.xml <span style='color:#111;'> 495B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_tx_5_0_7_RELEASE.xml <span style='color:#111;'> 602B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_boot_spring_boot_starter_test_2_0_3_RELEASE.xml <span style='color:#111;'> 727B </span>","children":null,"spread":false},{"title":"Maven__org_apache_logging_log4j_log4j_api_2_10_0.xml <span style='color:#111;'> 573B </span>","children":null,"spread":false}],"spread":false},{"title":"workspace.xml <span style='color:#111;'> 3.52KB </span>","children":null,"spread":false},{"title":"encodings.xml <span style='color:#111;'> 177B </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 451B </span>","children":null,"spread":false},{"title":"modules.xml <span style='color:#111;'> 373B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 815B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]

评论信息

免责申明

【只为小站】的资源来自网友分享,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论 【只为小站】 经营者是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二条之规定,若资源存在侵权或相关问题请联系本站客服人员,zhiweidada#qq.com,请把#换成@,本站将给予最大的支持与配合,做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明