@@ -273,7 +273,6 @@ func (d FakeDockerClient) Info(ctx context.Context) (types.Info, error) {
|
||||
Name: "absol",
|
||||
SwapLimit: false,
|
||||
IPv4Forwarding: true,
|
||||
ExecutionDriver: "native-0.2",
|
||||
ExperimentalBuild: false,
|
||||
CPUCfsPeriod: true,
|
||||
RegistryConfig: ®istry.ServiceConfig{
|
||||
|
||||
@@ -109,6 +109,7 @@ func (k *Kafka) Connect() error {
|
||||
config.Producer.RequiredAcks = sarama.RequiredAcks(k.RequiredAcks)
|
||||
config.Producer.Compression = sarama.CompressionCodec(k.CompressionCodec)
|
||||
config.Producer.Retry.Max = k.MaxRetry
|
||||
config.Producer.Return.Successes = true
|
||||
|
||||
// Legacy support ssl config
|
||||
if k.Certificate != "" {
|
||||
|
||||
Reference in New Issue
Block a user