Skip to content

[bug] rocketmq source can't work cause of no namesrv is set #34

New issue
New issue
Closed
#35
Closed
[bug] rocketmq source can't work cause of no namesrv is set#34
#35
Assignees
duhenglucky
@francisoliverlee

Description

@francisoliverlee
francisoliverlee
opened on Aug 22, 2021

rocketmq-streams/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java

Lines 52 to 68 in 5dbcd1d

public DataStream fromRocketmq(String topic, String groupName) {
return fromRocketmq(topic, groupName, null, false);
}
public DataStream fromRocketmq(String topic, String groupName, boolean isJson) {
return fromRocketmq(topic, groupName, null, isJson);
}
public DataStream fromRocketmq(String topic, String groupName, String tags, boolean isJson) {
RocketMQSource rocketMQSource = new RocketMQSource();
rocketMQSource.setTopic(topic);
rocketMQSource.setTags(tags);
rocketMQSource.setGroupName(groupName);
rocketMQSource.setJsonData(isJson);
this.mainPipelineBuilder.setSource(rocketMQSource);
return new DataStream(this.mainPipelineBuilder, this.otherPipelineBuilders, null);
}

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions