修改验证数据
This commit is contained in:
@@ -68,7 +68,7 @@ public class NameplateKafkaConsumer {
|
|||||||
}
|
}
|
||||||
// 手动提交 offset
|
// 手动提交 offset
|
||||||
if (ack != null) {
|
if (ack != null) {
|
||||||
log.info("nameplateKafkaConsumer ack.acknowledge");
|
log.info("nameplateKafkaConsumerack.acknowledge");
|
||||||
ack.acknowledge();
|
ack.acknowledge();
|
||||||
}
|
}
|
||||||
}else {
|
}else {
|
||||||
|
|||||||
Reference in New Issue
Block a user