Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- static void Main(string[] args)
- {
- string bootstrapServers = "localhost:9092";
- string schemaRegistryUrl = "Production163:8081";
- string topicName = "player";
- string groupName = "avro-generic-example-group";
- //CancellationTokenSource cts = new CancellationTokenSource();
- //var consumeTask = Task.Run(() =>
- //{
- using (var schemaRegistry = new CachedSchemaRegistryClient(new SchemaRegistryConfig { SchemaRegistryUrl = schemaRegistryUrl }))
- using (var consumer =
- new
- ConsumerBuilder<string, GenericRecord>(new ConsumerConfig { BootstrapServers = bootstrapServers, GroupId = groupName })
- .SetKeyDeserializer(new AsyncAvroDeserializer<string>(schemaRegistry).AsSyncOverAsync())
- .SetValueDeserializer(new AsyncAvroDeserializer<GenericRecord>(schemaRegistry).AsSyncOverAsync())
- .SetErrorHandler((_, e) => Console.WriteLine($"Error: {e.Reason}"))
- .Build())
- {
- consumer.Subscribe(topicName);
- try
- {
- while (true)
- {
- try
- {
- var consumeResult = consumer.Consume();
- Console.WriteLine($"Key: {consumeResult.Message.Key}nValue: {consumeResult.Value}");
- Console.WriteLine(consumeResult.Value.Schema);
- Console.WriteLine(consumeResult.Value.Schema["favorite_number"].GetProperty("favorite_number"));
- Console.WriteLine(consumeResult.Value.Schema["favorite_number"]);
- Avro.Field f;
- //consumeResult.Value
- consumeResult.Value.Schema.TryGetField("favorite_number", out f);
- Console.WriteLine(consumeResult.Value["favorite_number"]);
- Console.WriteLine(consumeResult.Value["name"]);
- //consumeResult.Message.Value.TryGetValue("favorite_number");
- //Console.WriteLine(f.);
- }
- catch (ConsumeException e)
- {
- Console.WriteLine($"Consume error: {e.Error.Reason}");
- }
- }
- }
- catch (OperationCanceledException)
- {
- // commit final offsets and leave the group.
- consumer.Close();
- }
- }
- //});
- }
- string bootstrapServers = "localhost:9092";
- string schemaRegistryUrl = "Production163:8081";
- string topicName = "player";
- string groupName = "avro-generic-example-group";
- //CancellationTokenSource cts = new CancellationTokenSource();
- //var consumeTask = Task.Run(() =>
- //{
- using (var schemaRegistry = new CachedSchemaRegistryClient(new SchemaRegistryConfig { SchemaRegistryUrl = schemaRegistryUrl }))
- using (
- var consumer = new ConsumerBuilder<string, GenericRecord>(new ConsumerConfig { BootstrapServers = bootstrapServers, GroupId = groupName })
- .SetKeyDeserializer(new AsyncAvroDeserializer<string>(schemaRegistry).AsSyncOverAsync())
- .SetValueDeserializer(new AsyncAvroDeserializer<GenericRecord>(schemaRegistry).AsSyncOverAsync())
- .SetErrorHandler((_, e) => Debug.Log($"Error: {e.Reason}"))
- .Build())
- {
- Debug.Log("subscribe");
- consumer.Subscribe(topicName);
- //try
- //{
- while (true)
- {
- //try
- //{
- //CancellationTokenSource cts = new CancellationTokenSource();
- //cts.Token
- var consumeResult = consumer.Consume(TimeSpan.FromMilliseconds(1000));//TimeSpan.FromMilliseconds(50000)
- Debug.Log($"Key: {consumeResult.Message.Key}nValue: {consumeResult.Value}");
- Debug.Log(consumeResult.Value.Schema);
- Debug.Log(consumeResult.Value.Schema["favorite_number"].GetProperty("favorite_number"));
- Debug.Log(consumeResult.Value.Schema["favorite_number"]);
- Avro.Field f;
- //consumeResult.Value
- consumeResult.Value.Schema.TryGetField("favorite_number", out f);
- Debug.Log(consumeResult.Value["favorite_number"]);
- Debug.Log(consumeResult.Value["name"]);
- //consumeResult.Message.Value.TryGetValue("favorite_number");
- //Debug.Log(f.);
- yield return new WaitForSeconds(1);
- //}
- //catch (ConsumeException e)
- //{
- // Debug.Log($"Consume error: {e.Error.Reason}");
- //}
- }
- //}
- //catch (OperationCanceledException)
- //{
- // // commit final offsets and leave the group.
- // consumer.Close();
- //}
- }
- //});
- Debug.Log("Main end game.");
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement