Skip to content

Commit 70d0603

Browse files
mhowlettmhowlett
authored
tweak examples + add avro blog example (#507)
* tweak examples + add avro blog example * addressing review comments (partial) * addressing review comments
1 parent b03c76a commit 70d0603

File tree

19 files changed

+484
-250
lines changed

19 files changed

+484
-250
lines changed

‎Confluent.Kafka.sln‎

Lines changed: 34 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
12
Microsoft Visual Studio Solution File, Format Version 12.00
23
# Visual Studio 15
34
VisualStudioVersion = 15.0.27019.1
@@ -18,18 +19,14 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.Kafka.UnitTests",
1819
EndProject
1920
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.Kafka.VerifiableClient", "test\Confluent.Kafka.VerifiableClient\Confluent.Kafka.VerifiableClient.csproj", "{11FF917E-DBA7-4D5F-A407-9BFD6211E7E3}"
2021
EndProject
21-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AdvancedConsumer", "examples\AdvancedConsumer\AdvancedConsumer.csproj", "{73839CCE-2985-4AA4-8FA2-9DFC27E831DC}"
22+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Consumer", "examples\Consumer\Consumer.csproj", "{73839CCE-2985-4AA4-8FA2-9DFC27E831DC}"
2223
EndProject
23-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AdvancedProducer", "examples\AdvancedProducer\AdvancedProducer.csproj", "{EF047ED8-F6FF-40C3-A1BE-E3E963627103}"
24+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Producer", "examples\Producer\Producer.csproj", "{EF047ED8-F6FF-40C3-A1BE-E3E963627103}"
2425
EndProject
2526
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Misc", "examples\Misc\Misc.csproj", "{3BED8840-0890-4953-85FB-F6A7F82D767A}"
2627
EndProject
2728
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MultiProducer", "examples\MultiProducer\MultiProducer.csproj", "{877AE1AA-3DA6-4933-BE85-214AA623E222}"
2829
EndProject
29-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SimpleConsumer", "examples\SimpleConsumer\SimpleConsumer.csproj", "{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}"
30-
EndProject
31-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SimpleProducer", "examples\SimpleProducer\SimpleProducer.csproj", "{835A806F-D265-44CA-BA30-F71ABD33A1FC}"
32-
EndProject
3330
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.Kafka.Avro", "src\Confluent.Kafka.Avro\Confluent.Kafka.Avro.csproj", "{FAF96869-D279-4ECA-9C7F-6AEFFF688031}"
3431
EndProject
3532
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.SchemaRegistry", "src\Confluent.SchemaRegistry\Confluent.SchemaRegistry.csproj", "{661BE4AE-56B3-4ED9-A7E0-29D91B1C09DA}"
@@ -44,7 +41,11 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.SchemaRegistry.Un
4441
EndProject
4542
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Confluent.SchemaRegistry.IntegrationTests", "test\Confluent.SchemaRegistry.IntegrationTests\Confluent.SchemaRegistry.IntegrationTests.csproj", "{2F5F0775-3708-40B7-A71F-442E83F6BB3D}"
4643
EndProject
47-
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "AvroGeneric", "examples\AvroGeneric\AvroGeneric.csproj", "{A526023B-B642-402C-A196-B6E3B3F40BE2}"
44+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AvroGeneric", "examples\AvroGeneric\AvroGeneric.csproj", "{A526023B-B642-402C-A196-B6E3B3F40BE2}"
45+
EndProject
46+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ConfluentCloud", "examples\ConfluentCloud\ConfluentCloud.csproj", "{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}"
47+
EndProject
48+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "AvroBlogExamples", "examples\AvroBlogExamples\AvroBlogExamples.csproj", "{A315597D-29D9-4A57-9A41-994916803AB7}"
4849
EndProject
4950
Global
5051
GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -164,30 +165,6 @@ Global
164165
{877AE1AA-3DA6-4933-BE85-214AA623E222}.Release|x64.Build.0 = Release|Any CPU
165166
{877AE1AA-3DA6-4933-BE85-214AA623E222}.Release|x86.ActiveCfg = Release|Any CPU
166167
{877AE1AA-3DA6-4933-BE85-214AA623E222}.Release|x86.Build.0 = Release|Any CPU
167-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
168-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|Any CPU.Build.0 = Debug|Any CPU
169-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|x64.ActiveCfg = Debug|Any CPU
170-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|x64.Build.0 = Debug|Any CPU
171-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|x86.ActiveCfg = Debug|Any CPU
172-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Debug|x86.Build.0 = Debug|Any CPU
173-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|Any CPU.ActiveCfg = Release|Any CPU
174-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|Any CPU.Build.0 = Release|Any CPU
175-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|x64.ActiveCfg = Release|Any CPU
176-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|x64.Build.0 = Release|Any CPU
177-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|x86.ActiveCfg = Release|Any CPU
178-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1}.Release|x86.Build.0 = Release|Any CPU
179-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
180-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|Any CPU.Build.0 = Debug|Any CPU
181-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|x64.ActiveCfg = Debug|Any CPU
182-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|x64.Build.0 = Debug|Any CPU
183-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|x86.ActiveCfg = Debug|Any CPU
184-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Debug|x86.Build.0 = Debug|Any CPU
185-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|Any CPU.ActiveCfg = Release|Any CPU
186-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|Any CPU.Build.0 = Release|Any CPU
187-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|x64.ActiveCfg = Release|Any CPU
188-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|x64.Build.0 = Release|Any CPU
189-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|x86.ActiveCfg = Release|Any CPU
190-
{835A806F-D265-44CA-BA30-F71ABD33A1FC}.Release|x86.Build.0 = Release|Any CPU
191168
{FAF96869-D279-4ECA-9C7F-6AEFFF688031}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
192169
{FAF96869-D279-4ECA-9C7F-6AEFFF688031}.Debug|Any CPU.Build.0 = Debug|Any CPU
193170
{FAF96869-D279-4ECA-9C7F-6AEFFF688031}.Debug|x64.ActiveCfg = Debug|Any CPU
@@ -284,6 +261,30 @@ Global
284261
{A526023B-B642-402C-A196-B6E3B3F40BE2}.Release|x64.Build.0 = Release|Any CPU
285262
{A526023B-B642-402C-A196-B6E3B3F40BE2}.Release|x86.ActiveCfg = Release|Any CPU
286263
{A526023B-B642-402C-A196-B6E3B3F40BE2}.Release|x86.Build.0 = Release|Any CPU
264+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
265+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|Any CPU.Build.0 = Debug|Any CPU
266+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|x64.ActiveCfg = Debug|Any CPU
267+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|x64.Build.0 = Debug|Any CPU
268+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|x86.ActiveCfg = Debug|Any CPU
269+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Debug|x86.Build.0 = Debug|Any CPU
270+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|Any CPU.ActiveCfg = Release|Any CPU
271+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|Any CPU.Build.0 = Release|Any CPU
272+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|x64.ActiveCfg = Release|Any CPU
273+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|x64.Build.0 = Release|Any CPU
274+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|x86.ActiveCfg = Release|Any CPU
275+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA}.Release|x86.Build.0 = Release|Any CPU
276+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
277+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|Any CPU.Build.0 = Debug|Any CPU
278+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|x64.ActiveCfg = Debug|Any CPU
279+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|x64.Build.0 = Debug|Any CPU
280+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|x86.ActiveCfg = Debug|Any CPU
281+
{A315597D-29D9-4A57-9A41-994916803AB7}.Debug|x86.Build.0 = Debug|Any CPU
282+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|Any CPU.ActiveCfg = Release|Any CPU
283+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|Any CPU.Build.0 = Release|Any CPU
284+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|x64.ActiveCfg = Release|Any CPU
285+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|x64.Build.0 = Release|Any CPU
286+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|x86.ActiveCfg = Release|Any CPU
287+
{A315597D-29D9-4A57-9A41-994916803AB7}.Release|x86.Build.0 = Release|Any CPU
287288
EndGlobalSection
288289
GlobalSection(SolutionProperties) = preSolution
289290
HideSolutionNode = FALSE
@@ -298,8 +299,6 @@ Global
298299
{EF047ED8-F6FF-40C3-A1BE-E3E963627103} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
299300
{3BED8840-0890-4953-85FB-F6A7F82D767A} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
300301
{877AE1AA-3DA6-4933-BE85-214AA623E222} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
301-
{25002C63-82EE-43BF-A63F-A3D01AC5D0F1} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
302-
{835A806F-D265-44CA-BA30-F71ABD33A1FC} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
303302
{FAF96869-D279-4ECA-9C7F-6AEFFF688031} = {59EE4CB4-41F6-4CE5-96ED-F5EAE0164417}
304303
{661BE4AE-56B3-4ED9-A7E0-29D91B1C09DA} = {59EE4CB4-41F6-4CE5-96ED-F5EAE0164417}
305304
{E1AE307A-05F1-4CE5-80AC-EA8E8FF8E9F9} = {399116BF-334E-4F4F-BB63-F128707EBA85}
@@ -308,6 +307,8 @@ Global
308307
{29DA188E-CB20-4A9C-AC4E-50B442B9AC7D} = {399116BF-334E-4F4F-BB63-F128707EBA85}
309308
{2F5F0775-3708-40B7-A71F-442E83F6BB3D} = {399116BF-334E-4F4F-BB63-F128707EBA85}
310309
{A526023B-B642-402C-A196-B6E3B3F40BE2} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
310+
{8D0A39A0-4217-465B-96D9-B31EB2A3EAFA} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
311+
{A315597D-29D9-4A57-9A41-994916803AB7} = {5E013DDE-CA17-4B15-B1CA-E262B67DBD6A}
311312
EndGlobalSection
312313
GlobalSection(ExtensibilityGlobals) = postSolution
313314
SolutionGuid = {CC489066-2768-4B90-9C6D-5F360D877242}

‎examples/AdvancedConsumer/AdvancedConsumer.csproj‎

Lines changed: 0 additions & 13 deletions
This file was deleted.

‎examples/AvroBlogExamples/AvroBlogExamples.csproj‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
3+
<PropertyGroup>
4+
<OutputType>Exe</OutputType>
5+
<TargetFramework>netcoreapp2.0</TargetFramework>
6+
</PropertyGroup>
7+
8+
<ItemGroup>
9+
<PackageReference Include="Confluent.Kafka.Avro" Version="0.11.4" />
10+
</ItemGroup>
11+
12+
</Project>

‎examples/AvroBlogExamples/LogLevel.asvc‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"namespace": "MessageTypes",
3+
"type": "enum",
4+
"doc": "Enumerates the set of allowable log levels.",
5+
"name": "LogLevel",
6+
"symbols": ["None", "Verbose", "Info", "Warning", "Error"]
7+
}

‎examples/AvroBlogExamples/LogMessage.V1.asvc‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
{
2+
"namespace": "MessageTypes",
3+
"type": "record",
4+
"doc": "A simple log message type as used by this blog post.",
5+
"name": "LogMessage",
6+
"fields": [
7+
{ "name": "IP", "type": "string" },
8+
{ "name": "Message", "type": "string" },
9+
{ "name": "Severity", "type": MessageTypes.LogLevel }
10+
]
11+
}

‎examples/AvroBlogExamples/LogMessage.V2.asvc‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
{
2+
"namespace": "MessageTypes",
3+
"type": "record",
4+
"doc": "A simple log message type as used by this blog post.",
5+
"name": "LogMessage",
6+
"fields": [
7+
{ "name": "IP", "type": "string" },
8+
{ "name": "Message", "type": "string" },
9+
{ "name": "Tags",
10+
"type": { "type": "map",
11+
"values": "string"},
12+
"default": {}},
13+
{ "name": "Severity",
14+
"type": { "namespace": "MessageTypes",
15+
"type": "enum",
16+
"doc": "Enumerates the set of allowable log levels.",
17+
"name": "LogLevel",
18+
"symbols": ["None", "Verbose", "Info", "Warning", "Error"]}}
19+
]
20+
}

‎examples/AvroBlogExamples/MessageTypes/LogLevel.cs‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
// ------------------------------------------------------------------------------
2+
// <auto-generated>
3+
// Generated by avrogen, version 1.7.7.4
4+
// Changes to this file may cause incorrect behavior and will be lost if code
5+
// is regenerated
6+
// </auto-generated>
7+
// ------------------------------------------------------------------------------
8+
namespace MessageTypes
9+
{
10+
using System;
11+
using System.Collections.Generic;
12+
using System.Text;
13+
using global::Avro;
14+
using global::Avro.Specific;
15+
16+
public enum LogLevel
17+
{
18+
None,
19+
Verbose,
20+
Info,
21+
Warning,
22+
Error,
23+
}
24+
}

‎examples/AvroBlogExamples/MessageTypes/LogMessage.cs‎

Lines changed: 97 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,97 @@
1+
// ------------------------------------------------------------------------------
2+
// <auto-generated>
3+
// Generated by avrogen, version 1.7.7.4
4+
// Changes to this file may cause incorrect behavior and will be lost if code
5+
// is regenerated
6+
// </auto-generated>
7+
// ------------------------------------------------------------------------------
8+
namespace MessageTypes
9+
{
10+
using System;
11+
using System.Collections.Generic;
12+
using System.Text;
13+
using global::Avro;
14+
using global::Avro.Specific;
15+
16+
public partial class LogMessage : ISpecificRecord
17+
{
18+
public static Schema _SCHEMA = Schema.Parse(@"{""type"":""record"",""name"":""LogMessage"",""namespace"":""MessageTypes"",""fields"":[{""name"":""IP"",""type"":""string""},{""name"":""Message"",""type"":""string""},{""name"":""Tags"",""default"":{},""type"":{""type"":""map"",""values"":""string""}},{""name"":""Severity"",""type"":{""type"":""enum"",""name"":""LogLevel"",""namespace"":""MessageTypes"",""symbols"":[""None"",""Verbose"",""Info"",""Warning"",""Error""]}}]}");
19+
private string _IP;
20+
private string _Message;
21+
private IDictionary<string,System.String> _Tags;
22+
private MessageTypes.LogLevel _Severity;
23+
public virtual Schema Schema
24+
{
25+
get
26+
{
27+
return LogMessage._SCHEMA;
28+
}
29+
}
30+
public string IP
31+
{
32+
get
33+
{
34+
return this._IP;
35+
}
36+
set
37+
{
38+
this._IP = value;
39+
}
40+
}
41+
public string Message
42+
{
43+
get
44+
{
45+
return this._Message;
46+
}
47+
set
48+
{
49+
this._Message = value;
50+
}
51+
}
52+
public IDictionary<string,System.String> Tags
53+
{
54+
get
55+
{
56+
return this._Tags;
57+
}
58+
set
59+
{
60+
this._Tags = value;
61+
}
62+
}
63+
public MessageTypes.LogLevel Severity
64+
{
65+
get
66+
{
67+
return this._Severity;
68+
}
69+
set
70+
{
71+
this._Severity = value;
72+
}
73+
}
74+
public virtual object Get(int fieldPos)
75+
{
76+
switch (fieldPos)
77+
{
78+
case 0: return this.IP;
79+
case 1: return this.Message;
80+
case 2: return this.Tags;
81+
case 3: return this.Severity;
82+
default: throw new AvroRuntimeException("Bad index " + fieldPos + " in Get()");
83+
};
84+
}
85+
public virtual void Put(int fieldPos, object fieldValue)
86+
{
87+
switch (fieldPos)
88+
{
89+
case 0: this.IP = (System.String)fieldValue; break;
90+
case 1: this.Message = (System.String)fieldValue; break;
91+
case 2: this.Tags = (IDictionary<string,System.String>)fieldValue; break;
92+
case 3: this.Severity = (MessageTypes.LogLevel)fieldValue; break;
93+
default: throw new AvroRuntimeException("Bad index " + fieldPos + " in Put()");
94+
};
95+
}
96+
}
97+
}

0 commit comments

Comments
 (0)