|
|
@@ -169,18 +169,6 @@ public class XfOffsetServiceImpl implements IXfOffsetService {
|
|
|
return baseMapper.deleteByIds(ids) > 0;
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 根据topic和groupId查询offset
|
|
|
- *
|
|
|
- * @param topic
|
|
|
- * @param groupId
|
|
|
- * @return
|
|
|
- */
|
|
|
- @Override
|
|
|
- public Long selectOffsetByTopicAndGroupId(String topic, String groupId) {
|
|
|
- return baseMapper.selectOffsetByTopicAndGroupId(topic, groupId);
|
|
|
- }
|
|
|
-
|
|
|
/**
|
|
|
* 判断是否可以消费
|
|
|
*
|