kafka

const (
	// AutoOffsetResetSmallest automatically reset the offset to the smallest offset.
	AutoOffsetResetSmallest AutoOffsetReset = "smallest"
	// AutoOffsetResetEarliest automatically reset the offset to the smallest offset.
	AutoOffsetResetEarliest AutoOffsetReset = "earliest"
	// AutoOffsetResetBeginning automatically reset the offset to the smallest offset.
	AutoOffsetResetBeginning AutoOffsetReset = "beginning"
	// AutoOffsetResetLargest automatically reset the offset to the largest offset.
	AutoOffsetResetLargest AutoOffsetReset = "largest"
	// AutoOffsetResetLatest automatically reset the offset to the largest offset.
	AutoOffsetResetLatest AutoOffsetReset = "latest"
	// AutoOffsetResetEnd automatically reset the offset to the largest offset.
	AutoOffsetResetEnd AutoOffsetReset = "end"
	// AutoOffsetResetError trigger an error (ERR__AUTO_OFFSET_RESET) which is retrieved by
	// consuming messages and checking 'message->err'
	AutoOffsetResetError AutoOffsetReset = "error"
)

const (
	BrokerAddressFamilyAny  BrokerAddressFamily = "any"
	BrokerAddressFamilyIPv4 BrokerAddressFamily = "v4"
	BrokerAddressFamilyIPv6 BrokerAddressFamily = "v6"
)

const (
	// DebugContextGeneric enables generic client instance level debugging.
	// Includes initialization and termination debugging.
	// Client Type: producer, consumer
	DebugContextGeneric DebugContext = "generic"
	// DebugContextBroker enables broker and connection state debugging.
	// Client Type: producer, consumer
	DebugContextBroker DebugContext = "broker"
	// DebugContextTopic enables topic and partition state debugging. Includes leader changes.
	// Client Type: producer, consumer
	DebugContextTopic DebugContext = "topic"
	// DebugContextMetadata enables cluster and topic metadata retrieval debugging.
	// Client Type: producer, consumer
	DebugContextMetadata DebugContext = "metadata"
	// DebugContextFeature enables Kafka protocol feature support as negotiated with the broker.
	// Client Type: producer, consumer
	DebugContextFeature DebugContext = "feature"
	// DebugContextQueue enables message queue debugging.
	// Client Type: producer
	DebugContextQueue DebugContext = "queue"
	// DebugContextMessage enables message debugging. Includes information about batching, compression, sizes, etc.
	// Client Type: producer, consumer
	DebugContextMessage DebugContext = "msg"
	// DebugContextProtocol enables Kafka protocol request/response debugging. Includes latency (rtt) printouts.
	// Client Type: producer, consumer
	DebugContextProtocol DebugContext = "protocol"
	// DebugContextConsumerGroup enables low-level consumer group state debugging.
	// Client Type: consumer
	DebugContextConsumerGroup DebugContext = "cgrp"
	// DebugContextSecurity enables security and authentication debugging.
	// Client Type: producer, consumer
	DebugContextSecurity DebugContext = "security"
	// DebugContextFetch enables consumer message fetch debugging. Includes decision when and why messages are fetched.
	// Client Type: consumer
	DebugContextFetch DebugContext = "fetch"
	// DebugContextInterceptor enables interceptor interface debugging.
	// Client Type: producer, consumer
	DebugContextInterceptor DebugContext = "interceptor"
	// DebugContextPlugin enables plugin loading debugging.
	// Client Type: producer, consumer
	DebugContextPlugin DebugContext = "plugin"
	// DebugContextConsumer enables high-level consumer debugging.
	// Client Type: consumer
	DebugContextConsumer DebugContext = "consumer"
	// DebugContextAdmin enables admin API debugging.
	// Client Type: admin
	DebugContextAdmin DebugContext = "admin"
	// DebugContextIdempotentProducer enables idempotent Producer debugging.
	// Client Type: producer
	DebugContextIdempotentProducer DebugContext = "eos"
	// DebugContextMock enables mock cluster functionality debugging.
	// Client Type: producer, consumer
	DebugContextMock DebugContext = "mock"
	// DebugContextAssignor enables detailed consumer group partition assignor debugging.
	// Client Type: consumer
	DebugContextAssignor DebugContext = "assignor"
	// DebugContextConfig enables displaying set configuration properties on startup.
	// Client Type: producer, consumer
	DebugContextConfig DebugContext = "conf"
	// DebugContextAll enables all of the above.
	// Client Type: producer, consumer
	DebugContextAll DebugContext = "all"
)

const (
	// PartitionAssignmentStrategyRange assigns partitions on a per-topic basis.
	PartitionAssignmentStrategyRange PartitionAssignmentStrategy = "range"
	// PartitionAssignmentStrategyRoundRobin assigns partitions to consumers in a round-robin fashion.
	PartitionAssignmentStrategyRoundRobin PartitionAssignmentStrategy = "roundrobin"
	// PartitionAssignmentStrategyCooperativeSticky guarantees an assignment that is maximally balanced while preserving
	// as many existing partition assignments as possible while allowing cooperative rebalancing.
	PartitionAssignmentStrategyCooperativeSticky PartitionAssignmentStrategy = "cooperative-sticky"
)

const (
	// PartitionerRandom uses random distribution.
	PartitionerRandom Partitioner = "random"
	// PartitionerConsistent uses the CRC32 hash of key while Empty and NULL keys are mapped to single partition.
	PartitionerConsistent Partitioner = "consistent"
	// PartitionerConsistentRandom uses CRC32 hash of key while Empty and NULL keys are randomly partitioned.
	PartitionerConsistentRandom Partitioner = "consistent_random"
	// PartitionerMurmur2 uses Java Producer compatible Murmur2 hash of key while NULL keys are mapped to single partition.
	PartitionerMurmur2 Partitioner = "murmur2"
	// PartitionerMurmur2Random uses Java Producer compatible Murmur2 hash of key whileNULL keys are randomly partitioned.
	// This is functionally equivalent to the default partitioner in the Java Producer.
	PartitionerMurmur2Random Partitioner = "murmur2_random"
	// PartitionerFnv1a uses FNV-1a hash of key whileNULL keys are mapped to single partition.
	PartitionerFnv1a Partitioner = "fnv1a"
	// PartitionerFnv1aRandom uses FNV-1a hash of key whileNULL keys are randomly partitioned.
	PartitionerFnv1aRandom Partitioner = "fnv1a_random"
)