AI 助理
备案控制台

游客oivvge5t4c2zu_个人页

游客oivvge5t4c2zu
个人头像照片
文章
0
问答
3
视频
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力：

暂时未有相关通用技术能力~

云产品技术能力：

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息

2023年01月

正在加载, 请稍后...
暂无更多信息
  • 提交了问题 2023-01-12

    rocketmq5.0消费者启动报错provider.newPushConsumerBuilder().buil

  • 回答了问题 2023-01-12

    rocketmq5.0消费者启动报错provider.newPushConsumerBuilder().buil

    @EnableDiscoveryClient @EnableFeignClients @SpringBootApplication public class  OrganizationApplication {     public static void main(String[] args) throws InterruptedException, IOException, ClientException, ClientException {         SpringApplication.run(OrganizationApplication.class, args);         final ClientServiceProvider provider = ClientServiceProvider.loadService();         // Credential provider is optional for client configuration.         String accessKey = '';         String secretKey = '';         String endpoints = '192.168.1.46:8081';         ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()                 .setEndpoints(endpoints)                 .build();         String tag = '';         FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG);         String consumerGroup = 'please_rename_unique_group_name_4';         String topic = 'VENDING_DEVICE_TOPIC';         PushConsumer pushConsumer = provider.newPushConsumerBuilder()                 .setClientConfiguration(clientConfiguration)                 // Set the consumer group name.                 .setConsumerGroup(consumerGroup)                 // Set the subscription for the consumer.                 .setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression))                 .setMessageListener(messageView -> {                     // Handle the received message and return consume result.                     ByteBuffer body = messageView.getBody();                     String resultJson = StandardCharsets.UTF_8.decode(body).toString();                     System.out.println('消息监听'+resultJson);                     return ConsumeResult.SUCCESS;                 })                 .build();     } }
    踩0 评论0
  • 提交了问题 2023-01-10

    rocketmq provider.newPushConsumerBuilder().buil

  • 提交了问题 2023-01-09

    rocketmq消息者启动报错 IllegalStateException

正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息