Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Server ServerConfig Kafka KafkaConfig Consumer ConsumerConfig Producer ProducerConfig Replication ReplicationConfig }
Config for the proxy
type ConsumerConfig ¶
type ConsumerConfig struct { OffsetAutoCommitInterval duration `json:"offset_auto_commit_interval"` OffsetAutoReset reset `json:"offset_auto_reset"` ClaimPartitionRetryInterval duration `json:"claim_partition_retry_interval"` AutoReconnectInterval duration `json:"auto_reconnect_interval"` UnackManagerSize int `json:"unack_manager_size"` //sarama config ChannelBufferSize int `json:"channel_buffer_size"` FetchDefault int32 `json:"fetch_default"` MaxWaitTime duration `json:"max_wait_time"` MaxProcessingTime duration `json:"max_processing_time"` }
type KafkaConfig ¶
type ProducerConfig ¶
type ReplicationConfig ¶
Click to show internal directories.
Click to hide internal directories.