pkg.gl

Categorygithub.com/duanhf2012/origin/v2sysmodulekafkamodule

package

2.1.6

Repository: https://github.com/duanhf2012/origin.git

Documentation: pkg.go.dev

# Functions

NewConsumerConfig

No description provided by the author

NewProducerConfig

NewProducerConfig 新建producerConfig kafkaVersion kafka版本 returnErr，returnSucc 是否返回错误与成功 requiredAcks -1 #全量同步确认，强可靠性保证（当所有的 leader 和 follower 都接收成功时）#WaitForAll 1 #leader 确认收到, 默认（仅 leader 反馈）#WaitForLocal 0 #不确认，但是吞吐量大（不 care 结果） #NoResponse Idempotent（幂等）确保信息都准确写入一份副本,用于幂等生产者，当这一项设置为true的时候，生产者将保证生产的消息一定是有序且精确一次的 partitioner 生成分区器，用于选择向哪个分区发送信息,默认情况下对消息密钥进行散列.