570 packages tagged with “Kafka”
Confluent's .NET Client for Apache Kafka
The Apache Kafka C/C++ client library - redistributable
A .NET Client for Confluent Schema Registry
Provides an Avro Serializer and Deserializer for use with Confluent.Kafka with Confluent Schema Registry integration
Contains all KafkaFlow extendable interfaces
Motor.NET is a microservice framework based on Microsoft.Extensions.Hosting.
KafkaFlow main package
HealthChecks.Kafka is the health check package for Kafka.
Adapts KafkaFlow to use Microsoft Dependency Injection
Provides a Protobuf Serializer and Deserializer for use with Confluent.Kafka with Confluent Schema Registry integration
Provides a JSON Serializer and Deserializer for use with Confluent.Kafka with Confluent Schema Registry integration
Amazon Managed Streaming for Kafka (Amazon MSK). Amazon MSK is a service that you can use to easily build, monitor, and manage Apache Kafka clusters in the cloud.
JSON implementation for KafkaFlow serializer middleware using System.Text.Json
Helper to run KafkaFlow as a Hosted Service
Package Description
JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json
Serializer middleware for KafkaFlow
LogHandler implementation leveraging Microsoft Logging framework.
Provides an Avro Serializer and Deserializer compatible with Confluent.Kafka which integrate with Confluent Schema Registry
A KafkaFlow middleware to execute a handler class when a specific message arrives
Kafka extensions for CloudNative.CloudEvents
Provides extensions methods to use Schema Registry
Protobuf implementation for KafkaFlow serializer middleware using protobuf-net
Confluent.Kafka instrumentationusing the [System.Diagnostics.Activity](https://docs.microsoft.com/en-us/dotnet/api/system.diagnostics.activity) API
OpenTelemetry instrumentation for Confluent.Kafka
This libary vends encoded IAM v4 signatures which can be used as IAM Auth tokens to authenticate against an MSK cluster.
Protobuf implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Protobuf package
Allows KafkaFlow to use the Admin commands