DefaultMQPushConsumer consumer("CID_JfSiteConsume");
consumer.setSessionCredentials("×××××", "×××××", "ALIYUN");
consumer.setConsumeFromWhere(CONSUME_FROM_LAST_OFFSET);

// consumer.setMessageModel(BROADCASTING);
consumer.setNamesrvAddr("http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet");

// consumer.setGroupName("CID_JfSiteConsume");
// consumer.setNamesrvDomain(info.namesrv_domain);
// consumer.setInstanceName("CID_JfSiteConsume");
MyMsgListener msglistener;
consumer.registerMessageListener(&msglistener);
consumer.subscribe("SiteInformMessage", "*");

try
{
	consumer.start();
}
catch (MQClientException &e) 
{
	std::cout << e << std::endl;
}

std::cout << "consumer started";
std::string str;
std::cin >> str;

consumer.shutdown();

这是我的测试代码，无法收到消息。

Maven引入，1.57、1.58是没问题的

org.springframework.boot
spring-boot-starter-parent
2.0.2.RELEASE

错误日志如下：
attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'producerApplication': Injection of resource dependencies failed; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {@javax.annotation.Resource(shareable=true, lookup=, name=, description=, authenticationType=CONTAINER, type=class java.lang.Object, mappedName=)}
2018-06-27 16:45:55.325 INFO 3835 --- [ main] o.apache.catalina.core.StandardService : Stopping service [Tomcat]
2018-06-27 16:45:55.340 INFO 3835 --- [ main] ConditionEvaluationReportLoggingListener :

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2018-06-27 16:45:55.456 ERROR 3835 --- [ main] o.s.b.d.LoggingFailureAnalysisReporter :

APPLICATION FAILED TO START

Description:

A component required a bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' that could not be found.
- Bean method 'rocketMQTemplate' in 'RocketMQAutoConfiguration' not loaded because @ConditionalOnBean (types: org.apache.rocketmq.client.producer.DefaultMQProducer; SearchStrategy: all) did not find any beans of type org.apache.rocketmq.client.producer.DefaultMQProducer

Action:

Consider revisiting the conditions above or defining a bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' in your configuration.

Disconnected from the target VM, address: '127.0.0.1:55452', transport: 'socket'

Process finished with exit code 1

rocketmq-cpp/src/producer/DefaultMQProducer.cpp: tryToCompressMessage函数没有判断msg是否被压缩过，只判断了是否过大，如果压缩后发送失败进行重发并且body大小仍然>=getCompressMsgBodyOverHowmuch()， body会被压缩两次

spring-boot-starter-rocketmq怎么进行消息延迟发送

fix consume duplication issue when consumer or broker are frequent changes

BUG REPORT

when I try to build and run name server and broker on MAC,
using the following sh:

rocketmq-externals/rocketmq-docker/4.1.0-incubating/play.sh

name server is ok, but broker container was automatically KILLED and exit(137)

Anyway, I tried to start the broker in name server container.

The broker was automatically killed. Is there any suggestion?

error message:

root@46dca5673f74:/opt/rocketmq-4.1.0-incubating# sh bin/mqbroker -n localhost:9876 &
[1] 35
root@46dca5673f74:/opt/rocketmq-4.1.0-incubating# Killed

[1]+  Exit 137                sh bin/mqbroker -n localhost:9876

RocketMQ 查看消费者消费情况 ，请求如下：

/consumer/queryTopicByConsumer.query?consumerGroup=BIZ_LOG_ONS_PRODUCER_GROUP

报错内容：

{"status":-1,"data":null,"errMsg":"org.apache.rocketmq.client.exception.MQClientException: CODE: 206 DESC: Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message\nFor more information, please visit the url, http://rocketmq.apache.org/docs/faq/"}

实际的faq页面没找到相关的信息。

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

FEATURE REQUEST

1. Please describe the feature you are requesting.

I think it's very necessary to add javadocs since it would be convenient to learn the API usage for RocketMQ users, especially the fresh.

2. Provide any additional detail on your proposed use case for this feature.

• Add maven-javadoc-plugin in pom.xml
• Add javadocs directory including the lateset javadoc.
• Update the rocketmq-flink/README.md

2. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

should-have

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• no sub task

您好：
您已经有九个月没有更新代码了。
现在我们用的SpringBoot 2.0.0版本以上的。
引用了这个
<!--在pom.xml中添加依赖--> <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>spring-boot-starter-rocketmq</artifactId> <version>1.0.0</version> </dependency>

   照着demo写的，都会启动失败，老哥有空检查一下代码吧
   肯定是有些问题的。
   `
   Description:

Field rocketMQTemplate in com.newframe.NewFrameApplication required a bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' that could not be found.
- Bean method 'rocketMQTemplate' not loaded because @ConditionalOnClass did not find required class 'org.apache.rocketmq.client.impl.MQClientAPIImpl'
Action:
Consider revisiting the conditions above or defining a bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' in your configuration.
`

The issue tracker is ONLY used for bug report and feature request.

BUG REPORT

1. Please describe the issue you observed:

• Use cmake produce the sln file, open sln with visual studio 2010 to build the project

• Wish to get the static lib rocketmq.lib

• What did you see instead?
  See some errors, no stdbool.h, thread, etc

2. Please tell us about your environment:
   Windows 7 64bit, Visual studio 2010
3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

apache/rocketmq#438

When I set the listener to
@RocketMQMessageListener(topic = "aaaaa", messageModel = MessageModel.BROADCASTING, consumerGroup = "bbbb", consumeMode = ConsumeMode.ORDERLY)

The consumer does not receive any message at all,
I checked rocketmq console and can confirm that those message are successfully created from producer.

And, the consumer can consume message if I set the consumeMode to concurrently.

Could you please share some hints, what am I missing here to turn the consumer into "orderly" mode?

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:
   [rocketmq-console]switch for cluster doesn't work

• What did you do (The steps to reproduce)?
  build two broker clusters : clusterA and clusterB;
  open rocketmq conole, click 'cluster'
• What did you expect to see?
  I can switch in two clusters, and there are brokers in each cluster
• What did you see instead?
  I saw only one broker cluster, and I choose to switch another cluster, it showed nothing

2. Please tell us about your environment:
   mac
3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
   /cluster/list.query: "clusterAddrTable":{"sns-cluster1":["broker-a2"],"sns-cluster":["broker-b","broker-a"]}

1.RocketMQ + Spark Structured Streaming Integration Guide
2.It is not good to run according to guidance
val spark = SparkSession
.builder
.master("local[2]")
.appName("StructuredNetworkWordCount")
.getOrCreate()
val df = spark
.readStream
.format("org.apache.spark.sql.rocketmq.RocketMQSourceProvider")
.option("nameServer", "192.168.2.210:9876;192.168.2.211:9876")
.option("topic", "testtopic")
.option("groupId","streaming1")
.load()
df.printSchema()
df.selectExpr("CAST(body AS STRING)").groupBy("body").count()
val query = df.writeStream
.outputMode("update")
.format("console")
.start()
query.awaitTermination()
3.how to set groupId for rocketMq for identifying the consumer

FEATURE REQUEST

1. Please describe the feature you are requesting.

Add Sentinel samples for Apache RocketMQ.

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

FEATURE REQUEST

1. Please describe the feature you are requesting.

Some improvements for RocketMQ-Spark.

2. Provide any additional detail on your proposed use case for this feature.

Following is the change list:

• Upgraded RocketMQ version to 4.2.0
• Removed duplicated gitignore
• Removed author infos
• Enabled unit tests by default
• Removed the dependency of java class refer to scala RocketMqUtils
• Moved RocketMqRDD and MQPullInputDStream to the right directory. These two class should be in the org.apache.spark package due to the limit of being invoked APIs private[spark].
• Some minor code style and documents improvements

2. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

must-have

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• no sub tasks

When I start sprintboot with rocketmq , it show errors as following:

A component required a bean of type 'org.apache.rocketmq.spring.starter.core.RocketMQTemplate' that could not be found

• Bean method 'rocketMQTemplate' in 'RocketMQAutoConfiguration' not loaded because @ConditionalOnBean (types: org.apache.rocketmq.client.producer.DefaultMQProducer; SearchStrategy: all) did not find any beans

pom.xml

org.springframework.boot
spring-boot-starter-parent
1.5.8.RELEASE

application.properties
spring.rocketmq.name-server=127.0.0.1:9876

问题：

我有两个broker，分别是broker-a（Master），broker-b（Slave）。但是在rocketmq-console集群页面始终只会显示一个节点信息，必须刷新页面才能切换到另一个节点

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?

create kv abc in redis with expire
downstream data to rocketmq
fount that other key have the abc key expire value.

• What did you expect to see?

only that abc key with expire value.

2. Please tell us about your environment:

rocketmq-redis-1.0.0

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

FEATURE REQUEST

1. RocketMQ has supported the transaction message in version 4.4.0, but the rocketmq-spring-boot-starter has no the related support yet.

2. Provide any additional detail on your proposed use case for this feature:
   a. Declare the RocketMQTemplate;
   b. Create a new transactional (tx) producer with TransactionListener implementation class;
   c. Send transactional message with the tx-producer;
   d. Shutdown the tx-producer if not use it again.

3. It is a nice-to-have function. User can use the rocketMQTemplate to send transactional message and inject the TransactionListener implementation class.

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?

• What did you expect to see?

• What did you see instead?

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

This is a minor change.
Since we have merged the RocketMQ-Flink module into master, we'd better to update the home README.MD to add Rocketmq-Flink.

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?

• What did you expect to see?

• What did you see instead?

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

网络环境正常时启动消费者测试程序，完成订阅。
然后断开网络，1分钟左右，测试程序崩溃。

FEATURE REQUEST

1. Please describe the feature you are requesting.
   A bridge between IoT devices and RocketMQ is wanted.

2. Provide any additional detail on your proposed use case for this feature.
   We want our IoT devices which run on MQTT protocol to leverage the RocketMQ.

3. More details
   See the RIP-1: MQTT Bridge for more details

DefaultMQPushConsumer consumer("CID_JfSiteConsume");
consumer.setSessionCredentials("××××", "×××", "ALIYUN");
consumer.setConsumeFromWhere(CONSUME_FROM_FIRST_OFFSET);
consumer.setMessageModel(BROADCASTING);

// consumer.setNamesrvAddr("http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet");

// consumer.setGroupName("CID_JfSiteConsume");
consumer.setNamesrvDomain("http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet");
// consumer.setInstanceName("CID_JfSiteConsume");
MyMsgListener msglistener;
consumer.registerMessageListener(&msglistener);
consumer.subscribe("SiteInformMessage", "888");

rocketmq-mysql send ORDERLY message?

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:
   rocketmq-flume-souce packagename org.apache.rocketmq.flume.ng.souce is wrong!

• What did you do (The steps to reproduce)?
  change org.apache.rocketmq.flume.ng.souce to org.apache.rocketmq.flume.ng.source

• What did you expect to see?

• What did you see instead?

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>spring-boot-starter-rocketmq</artifactId>
        <version>1.0.0-SNAPSHOT</version>
    </dependency>

maven加载不到

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?

• What did you expect to see?

• What did you see instead?

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

FEATURE REQUEST

1. Please describe the feature you are requesting.

Currently RocketMQ already supports Spark RDD API as well as D-Stream. It would be nice if it also supports Spark SQL and Spark Structured Streaming.

By the way, the Spark SQL's API is very different from Spark's, so it's almost impossible if you need to integrate with Spark SQL or Structured Streaming.

2. Provide any additional detail on your proposed use case for this feature.

I want to use Spark SQL / Spark Structured Streaming with RocketMQ.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

I don't think there is a clear solution or workaround. As I described in part 1, it's almost impossible to use Structured Streaming with RocketMQ.

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

We may decompose the task into following sub-tasks, referred to the source code of spark-sql-kafka-0-10.

• RocketMQStreamSourceProvider
• RocketMQRelationProvider
• RocketMQStreamSinkProvider
• RocketMQCreatableRelationProvider
• RocketMQStreamWriteSupport
• RocketMQContinuousReadSupport

FEATURE REQUEST

1. 为4.2.0添加docker支持

example 里面的代码感觉不完整，mq_client_manager.go里面同样很多函数没有实现

resetOffset reset offset with length larger than maxInt will leads coredump issue

这个管理控制台有权限控制吗？

Hello:
mvnrepository doesn't have spring-boot-starter-rocketmq

		<dependency>
			<groupId>org.apache.rocketmq</groupId>
			<artifactId>spring-boot-starter-rocketmq</artifactId>
			<version>1.0.0-SNAPSHOT</version>
		</dependency>```

This pom doesn't work。

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:
   Judgment about message type not accurate in method getMessageType of DefaultRocketMQListenerContainer class when rocketMQListener is a proxy object and it always return Object.class .

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

When will the API be planned to support affairs? Now the authorities have supported it.

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

FEATURE REQUEST

1. Please describe the feature you are requesting.

I think it's very necessary to add javadocs since it would be convenient to learn the API usage for RocketMQ users, especially the fresh.

2. Provide any additional detail on your proposed use case for this feature.

• Add maven-javadoc-plugin in pom.xml
• Add javadocs directory including the lateset javadoc.
• Update the rocketmq-spark/README.md

2. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

should-have

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• no sub task

rocketmq-console supports SSL connection？

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:
   使用rocketmq-cpp example AsyncProducer异步生产报错

# 同步接口正常
./bin/SyncProducer -t test-mq -g Test-Group -n 28.163.0.67:9876 -m 200
nameserver: 28.163.0.67:9876
topic: test-mq
groupname: Test-Group
produce content: msgbody for test
msg  count: 200
thread count: 8
tps: 0
tps: 0
send RT more than: 2406 ms with msgid: 1CA3004300002A9F0000002061BEA9A8
send RT more than: 2407 ms with msgid: 1CA3004300002A9F0000002061BEABB4
send RT more than: 2407 ms with msgid: 1CA3004300002A9F0000002061BEAA2B
send RT more than: 2410 ms with msgid: 1CA3004300002A9F0000002061BEACBA
send RT more than: 2410 ms with msgid: 1CA3004300002A9F0000002061BEAC37
send RT more than: 2410 ms with msgid: 1CA3004300002A9F0000002061BEAAAE
send RT more than: 2407 ms with msgid: 1CA3004300002A9F0000002061BEAB31
per msg time: 12.175ms
========================finished==============================
send RT more than: 2809 ms with msgid: 1CA3004300002A9F0000002061BF149B
tps: 210


 # 异步接口
./AsyncProducer -t test-mq -g producerGroup -n 28.163.0.67:9876 -m 200
# 报错输出
nameserver: 28.163.0.67:9876
topic: test-mq
groupname: producerGroup
produce content: msgbody for test
msg  count: 200
thread count: 8
tps: 0
tps: 0
tps: 0
tps: 0
per msg time: 20.08ms
========================finished==============================
send ExceptionType:  , msg: send msg failed due to wait response timeout or network error,error:-1,in file </rocket-cpp/src/common/AsyncCallbackWrap.cpp> line:55

• What did you do (The steps to reproduce)?
  cd rocketmq-cpp && mkdir build && cd build && cmake .. && make
• What did you expect to see?
  producer success
• What did you see instead?
  error

2. Please tell us about your environment:
   Icon name: computer-vm
   Chassis: vm
   Virtualization: vmware
   Operating System: CentOS Linux 7 (Core)
   CPE OS Name: cpe:/o:centos:centos:7
   Kernel: Linux 3.10.0-327.el7.x86_64
   Architecture: x86-64

3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
   none

FEATURE REQUEST

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:

• sub-task1-issue-number: sub-task1 description here,
• sub-task2-issue-number: sub-task2 description here,
• ...

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>spring-boot-starter-rocketmq</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</dependency>

Failed to execute goal on project rocketmq-server: Could not resolve dependencies for project edu.maskleo:rocketmq-server:jar:0.0.1-SNAPSHOT: Could not find artifact org.apache.rocketmq:spring-boot-starter-rocketmq:jar:1.0.0-SNAPSHOT -> [Help 1]

为什么阿里云版本的rocketmq-client支持以下订阅方式而公版的不支持
consumer.subscribe("TopicTestMQ", "TagA||TagB", new MessageListener() { //订阅多个 Tag
public Action consume(Message message, ConsumeContext context) {
System.out.println("Receive: " + message);
return Action.CommitMessage;
}
});
//订阅另外一个 Topic
consumer.subscribe("TopicTestMQ-Other", "*", new MessageListener() { //订阅全部 Tag
public Action consume(Message message, ConsumeContext context) {
System.out.println("Receive: " + message);
return Action.CommitMessage;
}
});

现在go client支持orderly consumer方式吗？
什么时候能有个全功能的go client。

The command '/bin/sh -c curl https://dist.apache.org/repos/dist/release/incubator/rocketmq/${ROCKETMQ_VERSION}/rocketmq-all-${ROCKETMQ_VERSION}-bin-release.zip -o rocketmq.zip && unzip rocketmq.zip && mv apache-rocketmq-all/* . && rmdir apache-rocketmq-all && rm rocketmq.zip' returned a non-zero code: 9
Unable to find image 'apache/incubator-rocketmq-namesrv:4.0.0-incubating' locally
Trying to pull repository docker.io/apache/incubator-rocketmq-namesrv ...
Pulling repository docker.io/apache/incubator-rocketmq-namesrv
/usr/bin/docker-current: Error: image apache/incubator-rocketmq-namesrv:4.0.0-incubating not found.
See '/usr/bin/docker-current run --help'.
Unable to find image 'apache/incubator-rocketmq-broker:4.0.0-incubating' locally
Trying to pull repository docker.io/apache/incubator-rocketmq-broker ...
Pulling repository docker.io/apache/incubator-rocketmq-broker
/usr/bin/docker-current: Error: image apache/incubator-rocketmq-broker:4.0.0-incubating not found.
See '/usr/bin/docker-current run --help'

FEATURE REQUEST

1. add docker images for rocketmq-4.3.0

rocketmq-externals/rocketmq-go/ 是不是未完成版？ 心塞。

现在的1.2.0版本有没有demo，在使用时应该怎么使用？