NewBroker .

NewMessageCarrier .

NewWriter creates new Writer.

WithAllowPublishAutoTopicCreation .

WithAsync default：true.

WithBatchBytes default：1048576 bytes.

WithBatchSize batch.size default：100.

WithBatchTimeout linger.ms default：10ms.

WithCommitInterval .

WithCrc32Balancer .

WithDialer .

WithDialerTimeout .

WithEnableErrorLogger enable go-micro error logger.

WithEnableLogger enable go-micro info logger.

WithEnableOneTopicOneWriter .

WithErrorLogger inject error logger.

WithHashBalancer .

WithHeaders .

WithHeartbeatInterval .

WithLeastBytesBalancer .

WithLogger inject info logger.

WithMaxAttempts .

WithMaxBytes .

WithMaxWait fetch.max.wait.ms.

WithMessageKey .

WithMessageOffset .

WithMinBytes fetch.min.bytes.

WithMurmur2Balancer .

WithPartitionWatchInterval .

WithPlainMechanism .

WithPublishMaxAttempts .

WithQueueCapacity .

WithReaderConfig .

WithReadLagInterval .

WithReadTimeout default：10s.

WithRebalanceTimeout .

WithReferenceHashBalancer .

WithRetentionTime .

WithRetries .

WithRoundRobinBalancer .

WithScramMechanism .

WithSessionTimeout .

WithStartOffset .

WithWatchPartitionChanges .

WithWriterConfig .

WithWriteTimeout default：10s.