调用commitofsets时，从kafkastream next调用中提取的最新消息的偏移量的committed值是多少？或者消费者缓冲的最大偏移量的值或其他值？
xyhw6mcr1#
它将是使用者获取的最大值（即，由客户端使用next（）读取，不包括内部缓冲的值）。但是请注意，如果使用者用于示例化多个迭代器以供多个线程使用，那么它们都将一次提交—通常不是预期的行为，因为一个线程无法知道其他线程的处理状态。
1条答案
按热度按时间xyhw6mcr1#
它将是使用者获取的最大值（即，由客户端使用next（）读取，不包括内部缓冲的值）。
但是请注意，如果使用者用于示例化多个迭代器以供多个线程使用，那么它们都将一次提交—通常不是预期的行为，因为一个线程无法知道其他线程的处理状态。