我在启用了SSL的情况下配置了kafka(1.0)并将侦听器属性添加为listeners=PLAINTEXT://:9092,SSL://:9093
And Advertised listenersadvertisted.listeners=PLAINTEXT://PUBLICIP:9092,SSL://PUBLICIP:9093
我能够使用9092端口生成消息,但在启用SSL的情况下无法生成9093.以下是我得到的错误
[2018-05-03 10:51:41,990] ERROR Error when sending message to topic test with key: null, value: 16 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
Run Code Online (Sandbox Code Playgroud)
org.apache.kafka.common.errors.TimeoutException:60000毫秒后无法更新元数据.
这是我正在使用的生产者命令
bin/kafka-console-producer.sh --broker-list PUBLICIP1:9093,PUBLICIP2:9093,PUBLICIP3:9093 --topic test --property security.protocol=SSL --producer.config ~/client.properties
Run Code Online (Sandbox Code Playgroud)
以下是client.properties中的条目
security.protocol=SSL
ssl.truststore.location=/home/ubuntu/kafka.client.truststore.jks
ssl.truststore.password=trustpassword
Run Code Online (Sandbox Code Playgroud) 我用PIL打开了一个图像,如
image = Image.open("SomeImage.png")
Run Code Online (Sandbox Code Playgroud)
在上面画一些文字,如
draw = ImageDraw.Draw(image)
draw.text(Some parameters here)
Run Code Online (Sandbox Code Playgroud)
然后保存为
image.save("SomeOtherName.png")
Run Code Online (Sandbox Code Playgroud)
使用pygame.image打开它
this_image = pygame.image.load("SomeOtherName.png")
Run Code Online (Sandbox Code Playgroud)
我只是想在不保存的情况下这样做..这可能吗?保存然后加载需要花费大量时间(0.12秒是的,这就像我有多个需要此操作的图像一样).可以超越保存方法吗?