java操作kafka实例
资源文件列表
kafkademo/.gitignore , 333
kafkademo/.idea/compiler.xml , 818
kafkademo/.idea/encodings.xml , 209
kafkademo/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_2_3.xml , 568
kafkademo/.idea/libraries/Maven__ch_qos_logback_logback_core_1_2_3.xml , 547
kafkademo/.idea/libraries/Maven__com_fasterxml_classmate_1_3_4.xml , 522
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_9_0.xml , 644
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_9_4.xml , 595
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_4.xml , 623
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_datatype_jackson_datatype_jdk8_2_9_4.xml , 674
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_datatype_jackson_datatype_jsr310_2_9_4.xml , 688
kafkademo/.idea/libraries/Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_9_4.xml , 729
kafkademo/.idea/libraries/Maven__com_google_guava_guava_18_0.xml , 499
kafkademo/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_4_0.xml , 546
kafkademo/.idea/libraries/Maven__com_spring4all_swagger_spring_boot_starter_1_6_0_RELEASE.xml , 708
kafkademo/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml , 700
kafkademo/.idea/libraries/Maven__io_springfox_springfox_bean_validators_2_7_0.xml , 630
kafkademo/.idea/libraries/Maven__io_springfox_springfox_core_2_7_0.xml , 553
kafkademo/.idea/libraries/Maven__io_springfox_springfox_schema_2_7_0.xml , 567
kafkademo/.idea/libraries/Maven__io_springfox_springfox_spi_2_7_0.xml , 546
kafkademo/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_7_0.xml , 595
kafkademo/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_7_0.xml , 581
kafkademo/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_7_0.xml , 623
kafkademo/.idea/libraries/Maven__io_springfox_springfox_swagger_ui_2_7_0.xml , 595
kafkademo/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_6.xml , 580
kafkademo/.idea/libraries/Maven__io_swagger_swagger_models_1_5_13.xml , 552
kafkademo/.idea/libraries/Maven__javax_annotation_javax_annotation_api_1_3_2.xml , 611
kafkademo/.idea/libraries/Maven__javax_validation_validation_api_2_0_1_Final.xml , 611
kafkademo/.idea/libraries/Maven__junit_junit_4_12.xml , 455
kafkademo/.idea/libraries/Maven__net_bytebuddy_byte_buddy_1_7_10.xml , 536
kafkademo/.idea/libraries/Maven__net_bytebuddy_byte_buddy_agent_1_7_10.xml , 578
kafkademo/.idea/libraries/Maven__net_minidev_accessors_smart_1_2.xml , 542
kafkademo/.idea/libraries/Maven__net_minidev_json_smart_2_3.xml , 507
kafkademo/.idea/libraries/Maven__org_apache_kafka_kafka_clients_1_0_0.xml , 562
kafkademo/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_10_0.xml , 573
kafkademo/.idea/libraries/Maven__org_apache_logging_log4j_log4j_to_slf4j_2_10_0.xml , 608
kafkademo/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_core_8_5_28.xml , 625
kafkademo/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_28.xml , 611
kafkademo/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_websocket_8_5_28.xml , 660
kafkademo/.idea/libraries/Maven__org_assertj_assertj_core_3_9_1.xml , 535
kafkademo/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml , 532
kafkademo/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml , 553
kafkademo/.idea/libraries/Maven__org_hibernate_validator_hibernate_validator_6_0_7_Final.xml , 674
kafkademo/.idea/libraries/Maven__org_javassist_javassist_3_21_0_GA.xml , 550
kafkademo/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_2_Final.xml , 608
kafkademo/.idea/libraries/Maven__org_lz4_lz4_java_1_4.xml , 477
kafkademo/.idea/libraries/Maven__org_mapstruct_mapstruct_1_1_0_Final.xml , 564
kafkademo/.idea/libraries/Maven__org_mockito_mockito_core_2_15_0.xml , 542
kafkademo/.idea/libraries/Maven__org_objenesis_objenesis_2_6.xml , 508
kafkademo/.idea/libraries/Maven__org_ow2_asm_asm_5_0_4.xml , 472
kafkademo/.idea/libraries/Maven__org_projectlombok_lombok_1_18_8.xml , 524
kafkademo/.idea/libraries/Maven__org_reflections_reflections_0_9_11.xml , 551
kafkademo/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_5_0.xml , 537
kafkademo/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_28.xml , 534
kafkademo/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_25.xml , 513
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_2_0_0_RELEASE.xml , 636
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_2_0_0_RELEASE.xml , 734
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_2_0_0_RELEASE.xml , 692
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_json_2_0_0_RELEASE.xml , 727
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_2_0_0_RELEASE.xml , 748
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_2_0_0_RELEASE.xml , 727
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_tomcat_2_0_0_RELEASE.xml , 741
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_web_2_0_0_RELEASE.xml , 720
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_2_0_0_RELEASE.xml , 671
kafkademo/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_0_0_RELEASE.xml , 769
kafkademo/.idea/libraries/Maven__org_springframework_kafka_spring_kafka_2_1_4_RELEASE.xml , 647
kafkademo/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_core_1_2_0_RELEASE.xml , 693
kafkademo/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_metadata_1_2_0_RELEASE.xml , 721
kafkademo/.idea/libraries/Maven__org_springframework_retry_spring_retry_1_2_2_RELEASE.xml , 647
kafkademo/.idea/libraries/Maven__org_springframework_spring_aop_5_0_4_RELEASE.xml , 609
kafkademo/.idea/libraries/Maven__org_springframework_spring_beans_5_0_4_RELEASE.xml , 623
kafkademo/.idea/libraries/Maven__org_springframework_spring_context_5_0_4_RELEASE.xml , 637
kafkademo/.idea/libraries/Maven__org_springframework_spring_core_5_0_4_RELEASE.xml , 616
kafkademo/.idea/libraries/Maven__org_springframework_spring_expression_5_0_4_RELEASE.xml , 658
kafkademo/.idea/libraries/Maven__org_springframework_spring_jcl_5_0_4_RELEASE.xml , 609
kafkademo/.idea/libraries/Maven__org_springframework_spring_messaging_5_0_4_RELEASE.xml , 651
kafkademo/.idea/libraries/Maven__org_springframework_spring_test_5_0_4_RELEASE.xml , 616
kafkademo/.idea/libraries/Maven__org_springframework_spring_tx_5_0_4_RELEASE.xml , 602
kafkademo/.idea/libraries/Maven__org_springframework_spring_web_5_0_4_RELEASE.xml , 609
kafkademo/.idea/libraries/Maven__org_springframework_spring_webmvc_5_0_4_RELEASE.xml , 630
kafkademo/.idea/libraries/Maven__org_xerial_snappy_snappy_java_1_1_4.xml , 552
kafkademo/.idea/libraries/Maven__org_xmlunit_xmlunit_core_2_5_1.xml , 535
kafkademo/.idea/libraries/Maven__org_yaml_snakeyaml_1_19.xml , 495
kafkademo/.idea/misc.xml , 1270
kafkademo/.idea/modules.xml , 265
kafkademo/.idea/uiDesigner.xml , 8915
kafkademo/.idea/workspace.xml , 8760
kafkademo/.mvn/wrapper/MavenWrapperDownloader.java , 4629
kafkademo/.mvn/wrapper/maven-wrapper.jar , 48337
kafkademo/.mvn/wrapper/maven-wrapper.properties , 116
kafkademo/HELP.md , 310
kafkademo/kafkademo.iml , 10236
kafkademo/mvnw , 9114
kafkademo/mvnw.cmd , 5811
kafkademo/pom.xml , 2779
kafkademo/src/main/java/com/example/kafkademo/KafkademoApplication.java , 619
kafkademo/src/main/java/com/example/kafkademo/biz/KafkaProducerBiz.java , 546
kafkademo/src/main/java/com/example/kafkademo/kafka/KafkaConsumerTest.java , 2666
kafkademo/src/main/java/com/example/kafkademo/kafka/KafkaProducerTest.java , 2224
kafkademo/src/main/java/com/example/kafkademo/rest/KafkaController.java , 2540
kafkademo/src/main/resources/application-local.yml , 1424
kafkademo/src/main/resources/application-ng.yml , 1376
kafkademo/src/main/resources/application-pro.yml , 1505
kafkademo/src/main/resources/application-t131.yml , 1560
kafkademo/src/main/resources/application.yml , 146
kafkademo/src/rem.md , 1188
kafkademo/target/classes/application-local.yml , 1424
kafkademo/target/classes/application-ng.yml , 1376
kafkademo/target/classes/application-pro.yml , 1505
kafkademo/target/classes/application-t131.yml , 1560
kafkademo/target/classes/application.yml , 146
kafkademo/target/classes/com/example/kafkademo/KafkademoApplication.class , 905
kafkademo/target/classes/com/example/kafkademo/biz/KafkaProducerBiz.class , 1353
kafkademo/target/classes/com/example/kafkademo/kafka/KafkaConsumerTest.class , 3685
kafkademo/target/classes/com/example/kafkademo/kafka/KafkaProducerTest.class , 2929
kafkademo/target/classes/com/example/kafkademo/rest/KafkaController.class , 3407
kafkademo/target/kafkademo-1.0.0.jar , 29510918
kafkademo/target/kafkademo-1.0.0.jar.original , 13073
kafkademo/target/maven-archiver/pom.properties , 90
kafkademo/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst , 251
kafkademo/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst , 486
kafkademo/target/maven-status/maven-compiler-plugin/testCompile/default-testCompile/inputFiles.lst , 0