|
BrokerRouterExtensionsFetch Method
|
Fetches a single result for the specified topic and partitionID.
Namespace: KafkaAdaptersAssembly: KafkaAdapters (in KafkaAdapters.dll) Version: 2.4.207-beta
Syntax public static FetchResponse Fetch(
this BrokerRouter router,
string topic,
int partitionID = 0,
long offset = 0,
int maxBytes = 32768
)
<ExtensionAttribute>
Public Shared Function Fetch (
router As BrokerRouter,
topic As String,
Optional partitionID As Integer = 0,
Optional offset As Long = 0,
Optional maxBytes As Integer = 32768
) As FetchResponse
[<ExtensionAttribute>]
static member Fetch :
router : BrokerRouter *
topic : string *
?partitionID : int *
?offset : int64 *
?maxBytes : int
(* Defaults:
let _partitionID = defaultArg partitionID 0
let _offset = defaultArg offset 0
let _maxBytes = defaultArg maxBytes 32768
*)
-> FetchResponse
KafkaAdapters.BrokerRouterExtensions.Fetch = function(router, topic, partitionID, offset, maxBytes);
View SourceParameters
- router BrokerRouter
- Router used to fetch result.
- topic String
- Topic to fetch result from.
- partitionID Int32 (Optional)
- Partition ID to fetch result from.
- offset Int64 (Optional)
- Offset of topic to begin fetching result.
- maxBytes Int32 (Optional)
- Defines maximum size of request that can be adjusted for large serializations.
Return Value
FetchResponseA
FetchResponse instance, if available; otherwise,
null.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type
BrokerRouter. When you use instance method syntax to call this method, omit the first parameter. For more information, see
Extension Methods (Visual Basic) or
Extension Methods (C# Programming Guide).
See Also