-
Notifications
You must be signed in to change notification settings - Fork 1
/
output-consume.txt
147 lines (120 loc) · 7.93 KB
/
output-consume.txt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
*********************************************************************
Using schemas from appending-new-field
*********************************************************************
===================================================================
Unusual option 1:
Use the v1 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Unusual option 2:
Use the v2 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (java.io.EOFException)
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222, "myBiscuit": "hobnob"}
===================================================================
Unusual option 3:
Use the v1 schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111, "myBiscuit": "rich tea"}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222, "myBiscuit": "rich tea"}
===================================================================
Unusual option 4:
Use the v2 schema for writer, and v1 schema for reader
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (java.io.EOFException)
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 1:
Use the correct schema for writer, and v1 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 2:
Use the correct schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111, "myBiscuit": "rich tea"}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222, "myBiscuit": "hobnob"}
===================================================================
*********************************************************************
Using schemas from prepending-new-field
*********************************************************************
===================================================================
Unusual option 1:
Use the v1 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "hobnob", "myFloat": 1.755433E25, "myInt": -58}
===================================================================
Unusual option 2:
Use the v2 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (org.apache.avro.AvroRuntimeException)
{"myBiscuit": "hobnob", "myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Unusual option 3:
Use the v1 schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myBiscuit": "rich tea", "myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myBiscuit": "rich tea", "myMessage": "hobnob", "myFloat": 1.755433E25, "myInt": -58}
===================================================================
Unusual option 4:
Use the v2 schema for writer, and v1 schema for reader
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (org.apache.avro.AvroRuntimeException)
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 1:
Use the correct schema for writer, and v1 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 2:
Use the correct schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myBiscuit": "rich tea", "myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myBiscuit": "hobnob", "myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
*********************************************************************
Using schemas from inserting-new-field
*********************************************************************
===================================================================
Unusual option 1:
Use the v1 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 6}
===================================================================
Unusual option 2:
Use the v2 schema (for both reader and writer) for both messages
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (java.io.EOFException)
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myBiscuit": "hobnob", "myInt": 222}
===================================================================
Unusual option 3:
Use the v1 schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myBiscuit": "rich tea", "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myBiscuit": "rich tea", "myInt": 6}
===================================================================
Unusual option 4:
Use the v2 schema for writer, and v1 schema for reader
-------------------------------------------------------------------
UNABLE TO DESERIALIZE (java.io.EOFException)
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 1:
Use the correct schema for writer, and v1 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myInt": 222}
===================================================================
Correct option 2:
Use the correct schema for writer, and v2 schema for reader
-------------------------------------------------------------------
{"myMessage": "This is message one, produced using the v1 schema", "myFloat": 1.1, "myBiscuit": "rich tea", "myInt": 111}
{"myMessage": "This is message two, produced using the v2 schema", "myFloat": 2.2, "myBiscuit": "hobnob", "myInt": 222}
===================================================================