KafkaFlow.Admin assembly

KafkaFlow namespace

public type	description
static class ClusterConfigurationBuilderExtensions	No needed

KafkaFlow.Admin namespace

public type	description
interface IConsumerAdmin	Expose Consumer administration features
interface ITelemetryStorage	Used to implement a telemetry data storage provider

KafkaFlow.Admin.Messages namespace

public type	description
class ChangeConsumerWorkersCount	A message to change the worker count
class ConsumerTelemetryMetric	A message that contains data related to consumers partition assigment
interface IAdminMessage	The interface that every admin message must implement
class PauseConsumerByName	A message that pauses a consumer
class PauseConsumersByGroup	The message that pauses an entire consumer group
class ResetConsumerOffset	The message that rewind the offset of all partitions/topics of a consumer to the beginning
class RestartConsumerByName	The message that destroy and recreates the internal consumer
class ResumeConsumerByName	The message that resume a paused consumer
class ResumeConsumersByGroup	The message that resume a paused consumer group
class RewindConsumerOffsetToDateTime	The message that rewind a consumer to a point in time
class StartConsumerByName	The message that starts a consumer
class StopConsumerByName	The message that stops a consumer