小编ves*_*che的帖子

我正在使用 kafka-python 向 Kafka 主题发送一些数据。我挣扎了一段时间无法将数据发送到我的 Kafka 主题，直到我发现如果我短暂延迟代码它就可以工作。

from kafka import KafkaProducer
from time import sleep

producer = KafkaProducer(bootstrap_servers="localhost:9092")
producer.send("topic", "foo")
sleep(.1)

此代码不适合我，而无需使用工作sleep(.1)。这就像发送数据需要时间来让它正常工作一样。kafka-python 客户端中是否有处理此问题的内容？或者更好的解决方案？

我已经在 Go 中编写了一个简单的客户端/服务器，它将通过 TLS 执行 HTTP GET，但我试图让它也能够通过 TLS 执行 HTTP POST。

在下面的示例中index.html只包含 text hello，并且 HTTP GET 工作正常。我希望客户端获取 HTTP GET 并写回hello world服务器。

客户

package main

import (
    "crypto/tls"
    "fmt"
    "io/ioutil"
    "net/http"
    "strings"
)

func main() {
    link := "https://10.0.0.1/static/index.html"

    tr := &http.Transport{
        TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
    }
    client := &http.Client{Transport: tr}
    response, err := client.Get(link)
    if err != nil {
        fmt.Println(err)
    }
    defer response.Body.Close()

    content, _ := ioutil.ReadAll(response.Body)
    s := strings.TrimSpace(string(content))

    fmt.Println(s)

    // out := s + …

我正试图通过变量对齐来对齐一些文本.

例如,这有效:

>>> print '{:>10}'.format('foo')
       foo

但这不是:

>>> x = 10
>>> print '{:>x}'.format('foo')