IQuixStreamingClient.GetRawTopicConsumer(string,string,Nullable AutoOffsetReset )

QuixStreams.Streaming

QuixStreams.Streaming.IQuixStreamingClient

IQuixStreamingClient.GetRawTopicConsumer(string, string, Nullable) Method

Gets a topic consumer capable of subscribing to receive non-quixstreams incoming messages.

QuixStreams.Streaming.Raw.IRawTopicConsumer GetRawTopicConsumer(string topicIdOrName, string consumerGroup=null, System.Nullable<QuixStreams.Telemetry.Kafka.AutoOffsetReset> autoOffset=null);

Parameters

topicIdOrName System.String

Id or name of the topic. If name is provided, workspace will be derived from environment variable or token, in that order

consumerGroup System.String

The consumer group id to use for consuming messages. If null, consumer group is not used and only consuming new messages.

autoOffset System.Nullable<

The offset to use when there is no saved offset for the consumer group.

Returns

IRawTopicConsumer
Instance of IRawTopicConsumer