dionjansen commented on a change in pull request #47:
URL: https://github.com/apache/pulsar-dotpulsar/pull/47#discussion_r446230216
##########
File path: samples/Consuming/Program.cs
##########
@@ -14,91 +14,93 @@
namespace Consuming
{
- using DotPulsar;
- using DotPulsar.Abstractions;
- using DotPulsar.Extensions;
- using System;
- using System.Buffers;
- using System.Text;
- using System.Threading;
- using System.Threading.Tasks;
-
- internal static class Program
+ using DotPulsar;
+ using DotPulsar.Abstractions;
+ using DotPulsar.Extensions;
+ using System;
+ using System.Buffers;
+ using System.Text;
+ using System.Threading;
+ using System.Threading.Tasks;
+
+ internal static class Program
+ {
+ private static async Task Main(string[] args)
{
- private static async Task Main(string[] args)
- {
- const string myTopic = "persistent://public/default/mytopic";
+ const string myTopic = "persistent://public/default/mytopic";
- await using var client = PulsarClient.Builder().Build();
//Connecting to pulsar://localhost:6650
+ await using var client = PulsarClient.Builder()
+ .ServiceUrl(new Uri("pulsar://host.docker.internal:6650"))
Review comment:
Agreed, will clean this up.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
