xunchangguo
xunchangguo
i hava same error. said need python. but which version of python is need?
how to solve this issue?
类似下面这样改？还是还有更好的方式？ ``` if (StringUtils.isNotEmpty(kafka010SourceTableInfo.getKafkaParam("group.id"))){ kafkaSrc.setStartFromGroupOffsets(); } else if("earliest".equalsIgnoreCase(offsetReset)){ kafkaSrc.setStartFromEarliest(); } ....................... ```
linux is ok