我是Avro和Kafka的新手。根據我對avro的理解,所有avro記錄都會附加一個模式。卡夫卡生產者將數據轉換爲字節數組並將其發送給卡夫卡消費者。消費者返回發送的數據。我的問題是如何在不引入模式註冊的概念的情況下從kafka消費者檢索模式。有沒有一種方法可以在不使用模式註冊表的情況下從kafka消費者獲取模式?從卡夫卡消費者檢索架構而不使用架構註冊表
1
A
回答
1
不,您在avro中序列化的kakfa消息只包含模式標識。此標識用於檢索模式註冊表上的良好模式。
0
在Avro編碼時,Avro Records將附有schemaId。該模式Id是用於獲取已用於編碼的模式的標識符。因爲在解碼時也使用相同的模式。 因此,基本上可以從記錄中獲取SchemaId,然後可以從模式註冊表中獲取該ID的相應模式,但不能從記錄本身獲取該模式。
相關問題
- 1. 卡夫卡消費者不消費
- 2. 卡夫卡架構演變
- 3. 春季XD卡夫卡源不註冊爲消費者?
- 4. 卡夫卡消費者不是從
- 5. 卡夫卡gruop消費者
- 6. 消費消費使用卡夫卡消費者 - Java
- 7. 如何從生產者消費卡夫卡的消費者?
- 8. 卡夫卡消費者/生產者API
- 9. 運行卡夫卡與連接器的Avro:ConfigException:「缺少架構註冊表URL」
- 10. 卡夫卡:多經紀人架構
- 11. 卡夫卡Avro架構演變
- 12. 卡夫卡10.2新消費者與舊消費者
- 13. 復位消費者在卡夫卡0.10
- 14. 無法創建卡夫卡消費者
- 15. Spark Streaming中的卡夫卡消費者
- 16. 卡夫卡消費者同步行爲
- 17. 問題在消費者卡夫卡
- 18. 暫停高級卡夫卡消費者
- 19. 卡夫卡消費者行爲
- 20. 關閉卡夫卡消費者
- 21. 卡夫卡消費者行爲
- 22. 春季集成卡夫卡消費者
- 23. 如何暫停卡夫卡消費者?
- 24. 卡夫卡消費者 - Java客戶端
- 25. 卡夫卡消費者與JAVA
- 26. 卡夫卡0.90消費者堅持
- 27. 雲中的卡夫卡消費者
- 28. 卡夫卡kafka.common.MessageSizeTooLargeException在消費者
- 29. 卡夫卡消費者滯後JMX
- 30. 卡夫卡:消費者崩潰
是否在kafka中,只有數據以沒有模式的字節數組格式發送?那麼如果沒有模式,反序列化是如何發生的呢? – Shri