Index - R
| RdKafkaRespErrAllBrokersDown | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrAssignPartitions | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrAuthentication | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrBadCompression | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrBadMsg | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrBegin | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrBrokerNotAvailable | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrClusterAuthorizationFailed | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrConflict | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrCritSysResource | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrDestroy | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrEnd | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrEndAll | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrExistingSubscription | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrFail | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrFs | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrGroupAuthorizationFailed | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrGroupCoordinatorNotAvailable | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrGroupLoadInProgress | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrIllegalGeneration | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrIllegalSaslState | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInconsistentGroupProtocol | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInProgress | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidArg | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidCommitOffsetSize | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidConfig | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidGroupId | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidMsg | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidMsgSize | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidPartitions | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidReplicaAssignment | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidReplicationFactor | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidRequest | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidRequiredAcks | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidSessionTimeout | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrInvalidTimestamp | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrIsrInsuff | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrLeaderNotAvailable | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrMsgSizeTooLarge | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrMsgTimedOut | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNetworkException | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNodeUpdate | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNoError | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNoOffset | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotController | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotCoordinatorForGroup | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotEnoughReplicas | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotEnoughReplicasAfterAppend | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotImplemented | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrNotLeaderForPartition | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrOffsetMetadataTooLarge | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrOffsetOutOfRange | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrOutdated | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrPartitionEof | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrPrevInProgress | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrQueueFull | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrRebalanceInProgress | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrRecordListTooLarge | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrReplicaNotAvailable | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrRequestTimedOut | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrResolve | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrRevokePartitions | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrSsl | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrStaleCtrlEpoch | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrState | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrT | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTimedOut | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTimedOutQueue | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTopicAlreadyExists | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTopicAuthorizationFailed | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTopicException | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrTransport | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknown | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownGroup | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownMemberId | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownPartition | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownProtocol | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownTopic | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnknownTopicOrPart | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnsupportedFeature | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnsupportedForMessageFormat | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnsupportedSaslMechanism | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrUnsupportedVersion | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrWaitCache | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| RdKafkaRespErrWaitCoord | Kafka.Conduit.Sink, Kafka.Conduit.Source, Kafka.Conduit |
| ReballanceCallback | |
| 1 (Data Constructor) | Kafka.Conduit.Source, Kafka.Conduit |
| 2 (Type/Class) | Kafka.Conduit.Source, Kafka.Conduit |
| reballanceCallback | Kafka.Conduit.Source, Kafka.Conduit |
| runConsumer | Kafka.Conduit.Source, Kafka.Conduit |
| runProducer | Kafka.Conduit.Sink, Kafka.Conduit |