AndreSteenbergen

public interface IEventTopicMapper
    {
        /// <summary>
        /// Determine the kafka topic and partion, as well as the key for this particular topic persistenceId
        /// </summary>
        /// <param name="persistenceId"></param>
        /// <returns></returns>
        Tuple<TopicPartition, byte[]> GetTopicPartitionForPersistenceId(string persistenceId);
    }

AndreSteenbergen

using System;
using System.Threading.Tasks;
using Akka.Streams.Stage;
using Akka.Util.Internal;
using Confluent.Kafka;

namespace Akka.Streams.Kafka.Stages
{
    internal sealed class ProducerStageLogicMock<K, V> : GraphStageLogic
    {

AndreSteenbergen

using Akka;
using Akka.Actor;
using Akka.Configuration;
using Akka.Streams;
using Akka.Streams.Dsl;
using Akka.Streams.Kafka.Dsl;
using Akka.Streams.Kafka.Messages;
using Akka.Streams.Kafka.Settings;
using Akka.Util;
using Confluent.Kafka;

AndreSteenbergen

/// <summary>
    /// Priority queue implemented using a simple list with binary search for inserts.
    /// This specific implementation is cheap in terms of memory but weak in terms of performance.
    /// See http://visualstudiomagazine.com/articles/2012/11/01/priority-queues-with-c.aspx for original implementation
    /// This specific version is adapted for Envelopes only and calculates a priority of envelope.Message
    /// </summary>
    public sealed class StableListPriorityQueue
    {
        
        private struct WrappedEnvelope