假设kafka喷口获取了一些消息,此时喷口任务被重新启动。提取的消息会丢失吗?我是三叉戟的初学者,我的问题是三叉戟Kafka事务/不透明喷口。提前谢谢!
hsgswve41#
我相信只要信息不是 ack 它们不会在被消耗时被提交,而喷口会在启动时重放它们。另一方面,如果您将喷口配置为从头开始读取,那么kafka sppout将从起始偏移点获取它们。
ack
1条答案
按热度按时间hsgswve41#
我相信只要信息不是
ack
它们不会在被消耗时被提交,而喷口会在启动时重放它们。另一方面,如果您将喷口配置为从头开始读取,那么kafka sppout将从起始偏移点获取它们。