lizhiboo

Support tag in litepullconsumer assign mode

1

The issue tracker is used for bug reporting purposes **ONLY** whereas feature request needs to follow the [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal). To avoid unnecessary duplication, please check whether there is a previous...

Is DefaultMQPullConsumer use RmqProducerGroup correct in ConnectUtil class?

2

line 87 in ConnectUtil ```java public static DefaultMQProducer initDefaultMQProducer(ConnectConfig connectConfig) { DefaultMQProducer producer = new DefaultMQProducer(); producer.setNamesrvAddr(connectConfig.getNamesrvAddr()); producer.setInstanceName(createInstance(connectConfig.getNamesrvAddr())); producer.setProducerGroup(createGroupNameV2(connectConfig.getRmqProducerGroup())); producer.setSendMsgTimeout(connectConfig.getOperationTimeout()); producer.setMaxMessageSize(RuntimeConfigDefine.MAX_MESSAGE_SIZE); producer.setLanguage(LanguageCode.JAVA); return producer; } public static DefaultMQPullConsumer initDefaultMQPullConsumer(ConnectConfig connectConfig)...

```java private SinkDataEntry convertToSinkDataEntry(MessageExt message) { Map properties = message.getProperties(); String queueName; EntryType entryType; Schema schema; Long timestamp; Object[] datas = new Object[1]; if (null == recordConverter || recordConverter instanceof...