Rewinding azure event hub offsets

RewindEventHub.linq

async Task Main()
{
  var connectionString = "Endpoint=sb://my-namespace.servicebus.windows.net/;SharedAccessKeyName=ReadEvents;SharedAccessKey=MySecretKey;EntityPath=hub";

	Console.WriteLine("Rewinding event hub...");
	var eventProcessorHost = new EventProcessorHost(
	"reporting",
	PartitionReceiver.DefaultConsumerGroupName,
	connectionString,
	"UseDevelopmentStorage=true",
	"azure-webjobs-eventhub");
	EventProcessorOptions options = new EventProcessorOptions()
	{
		InitialOffsetProvider = (partitionId) => EventPosition.FromEnqueuedTime(new DateTime(2019,12, 3,0,0,0))
	};
	await eventProcessorHost.RegisterEventProcessorAsync<SimpleEventProcessor>(options);

	await eventProcessorHost.UnregisterEventProcessorAsync();
}


public class SimpleEventProcessor : IEventProcessor
{	
	public Task CloseAsync(PartitionContext context, CloseReason reason) =>  Task.CompletedTask;
	
	public Task OpenAsync(PartitionContext context) =>  Task.CompletedTask;
	
	public Task ProcessErrorAsync(PartitionContext context, Exception error) => Task.CompletedTask;

	public Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages) => Task.CompletedTask;
}