177 packages tagged with “consumer”
Core of .NET suite for Apache Kafka. KNet is a comprehensive .NET suite for Apache Kafka providing all features: Producer, Consumer, Admin, Streams, Connect, backends (KRaft).
DequeNET (pronounced Deck Net) provides a concurrent lock-free deque C# implementation. A deque, or double-ended queue, is a data structure that allows insertion and removal of items on both ends. ConcurrentDeque<T> supports 6 operations in constant time O(1): PushRight, PopRight, PeekRight, PushLeft, PopLeft and PeekLeft. The library also offers a simpler Deque<T> (not thread safe), implemented as a ring buffer. This implementation allows Pop and Peek operations to run in O(1) time and Push operations in amortized O(1) time.
EntityFrameworkCore KNet - EntityFrameworkCore provider for Apache Kafka
EntityFrameworkCore KNet - Serialization support for EntityFrameworkCore provider for Apache Kafka
Service Activator for Paramore.Brighter Command Processor. Enables background message processing and task queue consumption for event-driven architectures. The Service Activator pattern decouples message reception from business logic execution.
A derivative of Soenneker.Blazor.Consumer.Base, providing instance-wide generic type setting.
Microsoft.Extensions.DependencyInjection integration for Paramore.Brighter Service Activator. Provides dependency injection container support for registering message consumers, performers, and service activator components.
An abstract wrapper around Soenneker.Blazor.ApiClient supporting auto (de)serialization for requests/responses/ProblemDetails.
EntityFrameworkCore KNet - Protobuf Serialization support for EntityFrameworkCore provider for Apache Kafka
EntityFrameworkCore KNet - Avro Serialization support for EntityFrameworkCore provider for Apache Kafka
Transformerizer: Parallel transform library for .NET
Kafka consumer host library to easily bootstrap a new app.
A wrapper around Soenneker.Blazor.ApiClient supporting auto (de)serialization for requests/responses/ProblemDetails.
Faster message broker tools using low-level implementations.
A collection of contructs for multi-threading
Command line interface of .NET suite for Apache Kafka. KNet is a comprehensive .NET suite for Apache Kafka providing all features: Producer, Consumer, Admin, Streams, Connect, backends (KRaft).
C# Consumer Client Implementation for Apache Kafka
A class that represents the core Blazor Consumer, providing no additional functionality than access to Soenneker.Blazor.ApiClient
Base Kafka Consumers
The Schema Generator for the Consumer Schema Tool
JSON Consumer
The Schema Checker for the Consumer Schema Tool
A template for creating Kafka consumer project in C#.
Datadog implementation of Orleans Telemetry API.
Package Description
ParallelTasks is a simple to use consumer-producer multithreading helper. (C# - Source file). Note: this nuget package contains c# source code and depends on .Net 4.0.
Parallelized Kafka consumer for maximizing throughput
Circuit breaker abstractions for SlimMessageBus
Ready made templates to create applications based on KNet. The templates are ready made starting points, all information and APIs are available in the official website https://knet.masesgroup.com