Skip to content

Commit

Permalink
resolve conflict
Browse files Browse the repository at this point in the history
  • Loading branch information
LGouellec committed Jul 30, 2024
2 parents 35c47ac + 40686a3 commit ecaa503
Showing 1 changed file with 3 additions and 6 deletions.
9 changes: 3 additions & 6 deletions samples/sample-stream/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@
using Streamiz.Kafka.Net.Metrics.Prometheus;
using Streamiz.Kafka.Net.SerDes;
using Streamiz.Kafka.Net.Stream;
using Microsoft.Extensions.Logging;
using Streamiz.Kafka.Net.Table;

namespace sample_stream
{
Expand All @@ -25,10 +27,6 @@ public static async Task Main(string[] args)
})
};

config["azure.remote.storage.uri"] = "URI";
config["azure.remote.storage.account.name"] = "ACCOUNT_NAME";
config["azure.remote.storage.account.key"] = "MASTER_KEY";

config.MetricsRecording = MetricsRecordingLevel.DEBUG;
config.UsePrometheusReporter(9090, true);

Expand All @@ -45,7 +43,6 @@ public static async Task Main(string[] args)
private static Topology BuildTopology()
{
var builder = new StreamBuilder();

/*builder.Stream<string, string>("input")
.GroupByKey()
.WindowedBy(TumblingWindowOptions.Of(windowSize))
Expand All @@ -68,4 +65,4 @@ private static Topology BuildTopology()
return builder.Build();
}
}
}
}

0 comments on commit ecaa503

Please sign in to comment.