【Flume】batchSize和transactionCapacity区别

大家好，又见面了，我是你们的朋友全栈君。

batchSize是针对Source和Sink提出的一个概念，它用来限制source和sink对event批量处理的。

即一次性你可以处理batchSize个event，这个一次性就是指在一个事务中。

当你处理的event数量超出了batchSize，那么事务就会提交了。

注意，这里有一个隐晦的地方，就是batchSize一定不能大于transactionCapacity

transactionCapacity这个概念来自于通道中，不同于batchSize(Source,Sink)，说白了，就是batchSize与transactionCapactiy相互传递数据，好比两个人相互递交文件，所以batchSize的容量要小于在channel内的transactionCapactiy，否则文件会溢出。

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/129454.html原文链接：https://javaforall.cn