- offset 內(nèi)容精選 換一換
-
member_status 否 String 共享狀態(tài) 枚舉值: pending accepted rejected name 否 String 名稱(chēng) offset 否 Integer 偏移值,正整數(shù) own_type 否 String 持有類(lèi)型,私有的private/共享的shared/全部al來(lái)自:百科
- offset 相關(guān)內(nèi)容
-
被分為多個(gè)分區(qū)(Partition),分區(qū)中存儲(chǔ)著一系列有序的消息,消息被順序?qū)懭敕謪^(qū)中,分區(qū)中的每個(gè)消息都被分配了一個(gè)唯一的偏移量(Offset),消息存儲(chǔ)在磁盤(pán)上,以保證數(shù)據(jù)的可靠性和持久性。 Kafka的生產(chǎn)者和消費(fèi)者通過(guò)Zookeeper來(lái)進(jìn)行協(xié)調(diào),Zookeeper主要來(lái)自:專(zhuān)題最小值:0 最大值:1000 缺省值:1000 name 否 String 保護(hù)組的名稱(chēng)。支持模糊查詢(xún)。 offset 否 Integer 每次請(qǐng)求開(kāi)始的下標(biāo),即偏移量,默認(rèn)值為0。offset必須為數(shù)字,不能為負(fù)數(shù)。 最小值:0 缺省值:0 query_type 否 String 查詢(xún)場(chǎng)景類(lèi)型。來(lái)自:百科
- offset 更多內(nèi)容
-
- OFFSET
- OFFSET
- LIMIT OFFSET下推
- LIMIT OFFSET下推簡(jiǎn)介
- 為什么offset不連續(xù)?
- 使用舊插件storm-kafka時(shí)如何正確設(shè)置offset
- LIMIT 2、LIMIT 2,3、LIMIT 2 OFFSET 3的區(qū)別?
- LIMIT 2、LIMIT 2,3、LIMIT 2 OFFSET 3的區(qū)別?
- FlinkSQL Kafka Connector支持offset從group組中恢復(fù),狀態(tài)從CheckPoint恢復(fù)
- 全量或增量階段失敗報(bào)錯(cuò),關(guān)鍵詞“The offset and file name between src and parser is inconsistency”