diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml deleted file mode 100644 index 40bcca10..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml +++ /dev/null @@ -1,56 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-example - ${revision} - - hippo4j-spring-boot-starter-adapter-kafka-example - - - - org.springframework.boot - spring-boot-starter - - - - org.springframework.boot - spring-boot-starter-web - - - - org.springframework.boot - spring-boot-starter-json - - - - org.projectlombok - lombok - - - - cn.hippo4j - hippo4j-spring-boot-starter-adapter-kafka - ${project.version} - - - - cn.hippo4j - hippo4j-spring-boot-starter - ${project.version} - - - - cn.hippo4j - hippo4j-example-core - ${revision} - - - - org.springframework.kafka - spring-kafka - - - diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java deleted file mode 100644 index 89b8c40b..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example; - -import cn.hippo4j.core.enable.EnableDynamicThreadPool; -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; - -@SpringBootApplication -@EnableDynamicThreadPool -public class ServerAdapterKafkaExampleApplication { - - public static void main(String[] args) { - SpringApplication.run(ServerAdapterKafkaExampleApplication.class, args); - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java deleted file mode 100644 index 43087cc9..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example.consumer; - -import lombok.extern.slf4j.Slf4j; -import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.kafka.support.Acknowledgment; -import org.springframework.kafka.support.KafkaHeaders; -import org.springframework.messaging.handler.annotation.Header; -import org.springframework.stereotype.Component; - -import java.util.Optional; - -/** - * Kafka message consumer. - */ -@Slf4j -@Component -public class KafkaMessageConsumer { - - @KafkaListener(topics = "kafka_message_hippo4j", groupId = "hippo4j") - public void onMessage(ConsumerRecord record, Acknowledgment ack, @Header(KafkaHeaders.RECEIVED_TOPIC) String topic) { - Optional message = Optional.ofNullable(record.value()); - message.ifPresent(each -> log.info(each.toString())); - ack.acknowledge(); - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java deleted file mode 100644 index 9cfbddbd..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example.produce; - -import cn.hippo4j.common.toolkit.IdUtil; -import cn.hippo4j.common.toolkit.JSONUtil; -import cn.hippo4j.example.core.dto.SendMessageDTO; -import lombok.AllArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.kafka.core.KafkaTemplate; -import org.springframework.stereotype.Component; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RestController; - -/** - * Kafka message produce. - */ -@Slf4j -@Component -@RestController -@AllArgsConstructor -public class KafkaMessageProduce { - - private final KafkaTemplate kafkaTemplate; - - private final String TOPIC = "kafka_message_hippo4j"; - - @GetMapping("/message/send") - public String sendMessage(Integer count) { - for (int i = 0; i < count; i++) { - String keys = IdUtil.randomUUID(); - SendMessageDTO payload = SendMessageDTO.builder() - .receiver("156011xxx91") - .uid(keys) - .build(); - kafkaTemplate.send(TOPIC, JSONUtil.toJSONString(payload)); - } - return "success"; - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties deleted file mode 100644 index fe298e76..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties +++ /dev/null @@ -1,23 +0,0 @@ -server.port=8092 - -spring.profiles.active=dev -spring.dynamic.thread-pool.server-addr=http://localhost:6691 -spring.dynamic.thread-pool.namespace=prescription -spring.dynamic.thread-pool.item-id=dynamic-threadpool-example -spring.dynamic.thread-pool.username=admin -spring.dynamic.thread-pool.password=123456 - -spring.kafka.bootstrap-servers=127.0.0.1:9092 -spring.kafka.producer.retries=0 -spring.kafka.producer.batch-size=16384 -spring.kafka.producer.buffer-memory=33554432 -spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer -spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer -spring.kafka.producer.acks=1 -spring.kafka.consumer.auto-offset-reset=latest -spring.kafka.consumer.enable-auto-commit=false -spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer -spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer -spring.kafka.listener.concurrency=2 -spring.kafka.listener.ack-mode=manual_immediate -spring.kafka.listener.missing-topics-fatal=false diff --git a/hippo4j-example/pom.xml b/hippo4j-example/pom.xml index 8672119d..80999ea3 100644 --- a/hippo4j-example/pom.xml +++ b/hippo4j-example/pom.xml @@ -21,7 +21,6 @@ hippo4j-config-nacos-spring-boot-starter-example hippo4j-config-apollo-spring-boot-starter-example hippo4j-config-zookeeper-spring-boot-starter-example - hippo4j-spring-boot-starter-adapter-kafka-example hippo4j-spring-boot-starter-adapter-rabbitmq-example hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rabbitmq-example hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq-example diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue index 9cef3ce2..da1e1761 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue index a7422930..530275f6 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue index 4d9c41f9..1162ed67 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue index ab6b6790..64cea308 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue @@ -227,8 +227,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue index 47384c5b..b2c4918c 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue @@ -214,8 +214,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue index 0579bfd7..9dabd398 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue index f0dfb75b..f64b9c78 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue @@ -214,8 +214,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue index dfac0769..17c4fb9a 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' },