File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ class Program
98
98
{
99
99
try
100
100
{
101
- var dr = await p .ProduceAsync (" test-topic" , new Message <Null , string > { Value = " test" });
101
+ var dr = await p .ProduceAsync (" test-topic" , new Message <Null , string > { Value = " test" });
102
102
Console .WriteLine ($" Delivered '{dr .Value }' to '{dr .TopicPartitionOffset }'" );
103
103
}
104
104
catch (ProduceException < Null , string > e )
@@ -133,7 +133,7 @@ class Program
133
133
134
134
using (var p = new ProducerBuilder <Null , string >(conf ).Build ())
135
135
{
136
- for (int i = 0 ; i < 100 ; ++ i )
136
+ for (int i = 0 ; i < 100 ; ++ i )
137
137
{
138
138
p .Produce (" my-topic" , new Message <Null , string > { Value = i .ToString () }, handler );
139
139
}
@@ -174,7 +174,8 @@ class Program
174
174
175
175
CancellationTokenSource cts = new CancellationTokenSource ();
176
176
Console .CancelKeyPress += (_ , e ) => {
177
- e .Cancel = true ; // prevent the process from terminating.
177
+ // Prevent the process from terminating.
178
+ e .Cancel = true ;
178
179
cts .Cancel ();
179
180
};
180
181
You can’t perform that action at this time.
0 commit comments