Advertisement
TheBlueFireFox

Parsed Kafka Meta data

Apr 11th, 2025 (edited)
14
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 11.47 KB | None | 0 0
  1. CompactRecords {
  2. vec: CompactArray {
  3. vec: [
  4. RecordBatch {
  5. base_offset: 1,
  6. batch_length: 79,
  7. partition_leader_epoch: 1,
  8. magic: 2,
  9. crc: 2959689084,
  10. attributes: RecordsAttribute {
  11. val: 0,
  12. },
  13. last_offset_delta: 0,
  14. base_timestamp: 1726045943832,
  15. max_timestamp: 1726045943832,
  16. producer_id: -1,
  17. producer_epoch: -1,
  18. base_sequence: -1,
  19. records_count: 1,
  20. records: [
  21. Record {
  22. length: Varint {
  23. val: 29,
  24. },
  25. attributes: 0,
  26. timestamp_delta: Varlong {
  27. val: 0,
  28. },
  29. offset_delta: Varint {
  30. val: 0,
  31. },
  32. key_length: Varint {
  33. val: -1,
  34. },
  35. key: [],
  36. value_length: Varint {
  37. val: 23,
  38. },
  39. value: [
  40. 1, 12, 0, 17, 109, 101, 116, 97, 100, 97, 116, 97,
  41. 46, 118, 101, 114, 115, 105, 111, 110, 0, 20, 0,
  42. ],
  43. headers_count: Varint {
  44. val: 0,
  45. },
  46. headers: [],
  47. },
  48. ],
  49. },
  50. RecordBatch {
  51. base_offset: 2,
  52. batch_length: 154,
  53. partition_leader_epoch: 1,
  54. magic: 2,
  55. crc: 4003530743,
  56. attributes: RecordsAttribute {
  57. val: 0,
  58. },
  59. last_offset_delta: 1,
  60. base_timestamp: 1726045957397,
  61. max_timestamp: 1726045957397,
  62. producer_id: -1,
  63. producer_epoch: -1,
  64. base_sequence: -1,
  65. records_count: 2,
  66. records: [
  67. Record {
  68. length: Varint {
  69. val: 30,
  70. },
  71. attributes: 0,
  72. timestamp_delta: Varlong {
  73. val: 0,
  74. },
  75. offset_delta: Varint {
  76. val: 0,
  77. },
  78. key_length: Varint {
  79. val: -1,
  80. },
  81. key: [],
  82. value_length: Varint {
  83. val: 24,
  84. },
  85. value: [
  86. 1, 2, 0, 4, 98, 97, 122, 0, 0, 0, 0, 0, 0, 64, 0,
  87. 128, 0, 0, 0, 0, 0, 0, 82, 0,
  88. ],
  89. headers_count: Varint {
  90. val: 0,
  91. },
  92. headers: [],
  93. },
  94. Record {
  95. length: Varint {
  96. val: 72,
  97. },
  98. attributes: 0,
  99. timestamp_delta: Varlong {
  100. val: 0,
  101. },
  102. offset_delta: Varint {
  103. val: 1,
  104. },
  105. key_length: Varint {
  106. val: -1,
  107. },
  108. key: [],
  109. value_length: Varint {
  110. val: 65,
  111. },
  112. value: [
  113. 1, 3, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 64, 0, 128,
  114. 0, 0, 0, 0, 0, 0, 82, 2, 0, 0, 0, 1, 2, 0, 0, 0, 1,
  115. 1, 1, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 2, 16, 0,
  116. 0, 0, 0, 0, 64, 0, 128, 0, 0, 0, 0, 0, 0, 1, 0,
  117. ],
  118. headers_count: Varint {
  119. val: 0,
  120. },
  121. headers: [],
  122. },
  123. ],
  124. },
  125. RecordBatch {
  126. base_offset: 4,
  127. batch_length: 154,
  128. partition_leader_epoch: 1,
  129. magic: 2,
  130. crc: 2637888855,
  131. attributes: RecordsAttribute {
  132. val: 0,
  133. },
  134. last_offset_delta: 1,
  135. base_timestamp: 1726045957397,
  136. max_timestamp: 1726045957397,
  137. producer_id: -1,
  138. producer_epoch: -1,
  139. base_sequence: -1,
  140. records_count: 2,
  141. records: [
  142. Record {
  143. length: Varint {
  144. val: 30,
  145. },
  146. attributes: 0,
  147. timestamp_delta: Varlong {
  148. val: 0,
  149. },
  150. offset_delta: Varint {
  151. val: 0,
  152. },
  153. key_length: Varint {
  154. val: -1,
  155. },
  156. key: [],
  157. value_length: Varint {
  158. val: 24,
  159. },
  160. value: [
  161. 1, 2, 0, 4, 113, 117, 120, 0, 0, 0, 0, 0, 0, 64, 0,
  162. 128, 0, 0, 0, 0, 0, 0, 103, 0,
  163. ],
  164. headers_count: Varint {
  165. val: 0,
  166. },
  167. headers: [],
  168. },
  169. Record {
  170. length: Varint {
  171. val: 72,
  172. },
  173. attributes: 0,
  174. timestamp_delta: Varlong {
  175. val: 0,
  176. },
  177. offset_delta: Varint {
  178. val: 1,
  179. },
  180. key_length: Varint {
  181. val: -1,
  182. },
  183. key: [],
  184. value_length: Varint {
  185. val: 65,
  186. },
  187. value: [
  188. 1, 3, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 64, 0, 128,
  189. 0, 0, 0, 0, 0, 0, 103, 2, 0, 0, 0, 1, 2, 0, 0, 0,
  190. 1, 1, 1, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 2, 16,
  191. 0, 0, 0, 0, 0, 64, 0, 128, 0, 0, 0, 0, 0, 0, 1, 0,
  192. ],
  193. headers_count: Varint {
  194. val: 0,
  195. },
  196. headers: [],
  197. },
  198. ],
  199. },
  200. RecordBatch {
  201. base_offset: 6,
  202. batch_length: 228,
  203. partition_leader_epoch: 1,
  204. magic: 2,
  205. crc: 497251715,
  206. attributes: RecordsAttribute {
  207. val: 0,
  208. },
  209. last_offset_delta: 2,
  210. base_timestamp: 1726045957397,
  211. max_timestamp: 1726045957397,
  212. producer_id: -1,
  213. producer_epoch: -1,
  214. base_sequence: -1,
  215. records_count: 3,
  216. records: [
  217. Record {
  218. length: Varint {
  219. val: 30,
  220. },
  221. attributes: 0,
  222. timestamp_delta: Varlong {
  223. val: 0,
  224. },
  225. offset_delta: Varint {
  226. val: 0,
  227. },
  228. key_length: Varint {
  229. val: -1,
  230. },
  231. key: [],
  232. value_length: Varint {
  233. val: 24,
  234. },
  235. value: [
  236. 1, 2, 0, 4, 113, 117, 122, 0, 0, 0, 0, 0, 0, 64, 0,
  237. 128, 0, 0, 0, 0, 0, 0, 33, 0,
  238. ],
  239. headers_count: Varint {
  240. val: 0,
  241. },
  242. headers: [],
  243. },
  244. Record {
  245. length: Varint {
  246. val: 72,
  247. },
  248. attributes: 0,
  249. timestamp_delta: Varlong {
  250. val: 0,
  251. },
  252. offset_delta: Varint {
  253. val: 1,
  254. },
  255. key_length: Varint {
  256. val: -1,
  257. },
  258. key: [],
  259. value_length: Varint {
  260. val: 65,
  261. },
  262. value: [
  263. 1, 3, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 64, 0, 128, 0,
  264. 0, 0, 0, 0, 0, 33, 2, 0, 0, 0, 1, 2, 0, 0, 0, 1, 1, 1,
  265. 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 2, 16, 0, 0, 0, 0,
  266. 0, 64, 0, 128, 0, 0, 0, 0, 0, 0, 1, 0,
  267. ],
  268. headers_count: Varint {
  269. val: 0,
  270. },
  271. headers: [],
  272. },
  273. Record {
  274. length: Varint {
  275. val: 72,
  276. },
  277. attributes: 0,
  278. timestamp_delta: Varlong {
  279. val: 0,
  280. },
  281. offset_delta: Varint {
  282. val: 2,
  283. },
  284. key_length: Varint {
  285. val: -1,
  286. },
  287. key: [],
  288. value_length: Varint {
  289. val: 65,
  290. },
  291. value: [
  292. 1, 3, 1, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 64, 0,
  293. 128, 0, 0, 0, 0, 0, 0, 33, 2, 0, 0, 0, 1, 2, 0, 0, 0,
  294. 1, 1, 1, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 0, 0, 2, 16, 0,
  295. 0, 0, 0, 0, 64, 0, 128, 0, 0, 0, 0, 0, 0, 1, 0,
  296. ],
  297. headers_count: Varint {
  298. val: 0,
  299. },
  300. headers: [],
  301. },
  302. ],
  303. },
  304. ],
  305. },
  306. }
  307.  
  308.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement