Skip to main content
Version: 2.x

Samples

We know that working code is a valuable learning tool for many, so here you can find a list of samples built to demonstrate KafkaFlow capabilities.

Basic​

This is a simple sample that shows how to produce and consume messages.

You can find the code here: /samples/KafkaFlow.Sample

Batching​

This is a sample that shows batch processing using KafkaFlow.

You can find the code here: /samples/KafkaFlow.Sample.BatchOperations

Schema Registry​

This is a sample that shows how to use Schema Registry with KafkaFlow.

You can find the code here: /samples/KafkaFlow.Sample

Web API​

This sample shows how to host an administration Web API for administrative operations.

You can find the code here: /samples/KafkaFlow.Sample

Dashboard​

This sample shows how to use KafkaFlow to expose an administration Dashboard.

You can find the code here: /samples/KafkaFlow.Sample

Flow of Control​

This is a sample that shows how to control the state of a consumer (Starting, Pausing, Stopping, etc.) programmatically.

You can find the code here: /samples/KafkaFlow.Sample.FlowControl

Pause Consumer on Error​

This is a sample that shows how to stop the consumer when an exception is raised.

You can find the code here: /samples/KafkaFlow.Sample.PauseConsumerOnError

Consumer Throttling​

This is a sample that shows how to throttle a consumer based on others consumers lag

You can find the code here: /samples/KafkaFlow.Sample.ConsumerThrottling

Wildcard Consumers​

This sample shows how to use a consumer to handle all the topics according to a naming convention. This is not a feature of KafkaFlow, but a demonstration of how to use the pattern conventions exposed by librdkafka (here).

You can find the code here: /samples/KafkaFlow.Sample.WildcardConsumer