spring cloud stream rocket bug

[ooooo-youwillsee]

Which Component eg. Rocket

Describe the bug

java code

@Bean
Function<Message<String>, Message<String>> xxx() {
    ...
 }

bootstrap.yml

spring:
  cloud:
    stream:
      function:
        definition: xxx
      bindings:
        xxx-in-0:
          destination: topic1
          binder: a-binder
          group: topic1-group
        xxx-out-0:
          destination: topic2
          binder: b-binder
      binders:
        a-binder:
          type: rocketmq
          environment:
            spring:
              cloud:
                stream:
                  rocketmq:
                    binder:
                      name-server: localhost:9876
        b-binder:
          type: rocketmq
          environment:
            spring:
              cloud:
                stream:
                  rocketmq:
                    bindings:
                      xxx-out-0:
                        producer:
                          group: topic2-group
                          sync: true
                    binder:
                      name-server: localhost:9877

To Reproduce

message finally send the topic of 'a-binder' named 'topic2'

Expected behavior

message finally send the topic of 'b-binder' named 'topic1'

I found spring cloud stream not config 'instanceName', it will cause MQClientInstance is covered or not create second MQClientInstance

[zkzlx]

please provide your rocketmq version.

[ooooo-youwillsee]

rocketmq 4.9

[zkzlx]

Currently, rocketmq-stream not support the Function mode.

[github-actions[bot]]

This issue has been open 30 days with no activity. This will be closed in 7 days.

[github-actions[bot]]

This issue has been automatically marked as stale because it hasn't had any recent activity.If you think this should still be open, or the problem still persists, just pop a reply in the comments and one of the maintainers will (try!) to follow up. Thank you for your interest and contribution to the Sping Cloud Alibaba Community.