package kafka-eio

  1. Overview
  2. Docs
Eio-native Kafka client for OCaml 5, built on librdkafka

Install 

dune-project
 Dependency

github.com Readme Changelog Edit opam file Versions (1)

Authors

  1. L
    lbendtly

Maintainers

  1. L
    lbendtlynielsen@gmail.com

Sources

v0.1.1.tar.gz
md5=88c2b9c6d263a1eb114cc5d1b570288a
sha512=44f5395fcc58b8d4303bc0b36113a17193da3a1925125cb0742fabeb96f32eb6b243c98d2fde283b6c95872ff36ddbf96de6e98b7612799e2aefeb2f85a1db95

doc/kafka-eio.core/Kafka_error/index.html

Module Kafka_errorSource

OCaml mirror of librdkafka's rd_kafka_resp_err_t. Internal (negative) error codes and Kafka protocol (positive) error codes are both represented. The full variant list is autogenerated by scripts/gen_errors.sh.

Sourcetype t =
  1. | Unknown
  2. | Offset_out_of_range
  3. | Invalid_msg
  4. | Unknown_topic_or_part
  5. | Invalid_msg_size
  6. | Leader_not_available
  7. | Not_leader_for_partition
  8. | Request_timed_out
  9. | Broker_not_available
  10. | Replica_not_available
  11. | Msg_size_too_large
  12. | Stale_ctrl_epoch
  13. | Offset_metadata_too_large
  14. | Network_exception
  15. | Coordinator_load_in_progress
  16. | Coordinator_not_available
  17. | Not_coordinator
  18. | Topic_exception
  19. | Record_list_too_large
  20. | Not_enough_replicas
  21. | Not_enough_replicas_after_append
  22. | Invalid_required_acks
  23. | Illegal_generation
  24. | Inconsistent_group_protocol
  25. | Invalid_group_id
  26. | Unknown_member_id
  27. | Invalid_session_timeout
  28. | Rebalance_in_progress
  29. | Invalid_commit_offset_size
  30. | Topic_authorization_failed
  31. | Group_authorization_failed
  32. | Cluster_authorization_failed
  33. | Invalid_timestamp
  34. | Unsupported_sasl_mechanism
  35. | Illegal_sasl_state
  36. | Unsupported_version
  37. | Topic_already_exists
  38. | Invalid_partitions
  39. | Invalid_replication_factor
  40. | Invalid_replica_assignment
  41. | Invalid_config
  42. | Not_controller
  43. | Invalid_request
  44. | Unsupported_for_message_format
  45. | Policy_violation
  46. | Out_of_order_sequence_number
  47. | Duplicate_sequence_number
  48. | Invalid_producer_epoch
  49. | Invalid_txn_state
  50. | Invalid_producer_id_mapping
  51. | Invalid_transaction_timeout
  52. | Concurrent_transactions
  53. | Transaction_coordinator_fenced
  54. | Transactional_id_authorization_failed
  55. | Security_disabled
  56. | Operation_not_attempted
  57. | Kafka_storage_error
  58. | Log_dir_not_found
  59. | Sasl_authentication_failed
  60. | Unknown_producer_id
  61. | Reassignment_in_progress
  62. | Delegation_token_auth_disabled
  63. | Delegation_token_not_found
  64. | Delegation_token_owner_mismatch
  65. | Delegation_token_request_not_allowed
  66. | Delegation_token_authorization_failed
  67. | Delegation_token_expired
  68. | Invalid_principal_type
  69. | Non_empty_group
  70. | Group_id_not_found
  71. | Fetch_session_id_not_found
  72. | Invalid_fetch_session_epoch
  73. | Listener_not_found
  74. | Topic_deletion_disabled
  75. | Fenced_leader_epoch
  76. | Unknown_leader_epoch
  77. | Unsupported_compression_type
  78. | Stale_broker_epoch
  79. | Offset_not_available
  80. | Member_id_required
  81. | Preferred_leader_not_available
  82. | Group_max_size_reached
  83. | Fenced_instance_id
  84. | Eligible_leaders_not_available
  85. | Election_not_needed
  86. | No_reassignment_in_progress
  87. | Group_subscribed_to_topic
  88. | Invalid_record
  89. | Unstable_offset_commit
  90. | Throttling_quota_exceeded
  91. | Producer_fenced
  92. | Resource_not_found
  93. | Duplicate_resource
  94. | Unacceptable_credential
  95. | Inconsistent_voter_set
  96. | Invalid_update_version
  97. | Feature_update_failed
  98. | Principal_deserialization_failure
  99. | No_error
  100. | Begin
  101. | Bad_msg
  102. | Bad_compression
  103. | Destroy
  104. | Fail
  105. | Transport
  106. | Crit_sys_resource
  107. | Resolve
  108. | Msg_timed_out
  109. | Partition_eof
  110. | Unknown_partition
  111. | Fs
  112. | Unknown_topic
  113. | All_brokers_down
  114. | Invalid_arg
  115. | Timed_out
  116. | Queue_full
  117. | Isr_insuff
  118. | Node_update
  119. | Ssl
  120. | Wait_coord
  121. | Unknown_group
  122. | In_progress
  123. | Prev_in_progress
  124. | Existing_subscription
  125. | Assign_partitions
  126. | Revoke_partitions
  127. | Conflict
  128. | State
  129. | Unknown_protocol
  130. | Not_implemented
  131. | Authentication
  132. | No_offset
  133. | Outdated
  134. | Timed_out_queue
  135. | Unsupported_feature
  136. | Wait_cache
  137. | Intr
  138. | Key_serialization
  139. | Value_serialization
  140. | Key_deserialization
  141. | Value_deserialization
  142. | Partial
  143. | Read_only
  144. | Noent
  145. | Underflow
  146. | Invalid_type
  147. | Retry
  148. | Purge_queue
  149. | Purge_inflight
  150. | Fatal
  151. | Inconsistent
  152. | Gapless_guarantee
  153. | Max_poll_exceeded
  154. | Unknown_broker
  155. | Not_configured
  156. | Fenced
  157. | Application
  158. | Assignment_lost
  159. | Noop
  160. | Auto_offset_reset
  161. | Log_truncation
  162. | End
  163. | Err_unknown of int
  164. | Config_error of string
Sourceval of_int : int -> t
Sourceval to_string : t -> string
Sourceval is_retryable : t -> bool
Sourceval is_fatal : t -> bool