小编Cod*_*low的帖子

如何在google-colaboratory中运行docker镜像？我试图在google-colaboratory中安装docker服务。

但是，当我执行Docker的命令时，收到关于“无法在unix：///var/run/docker.sock上连接到Docker守护程序。docker守护程序正在运行？”的错误消息。

屏幕快照

我想知道如何解决这个问题？

谢谢

我正在尝试将客户端编写为生产者.我按照示例创建了一个新的win32控制台项目.我发现API不适用于我,除非我在程序结束时添加了getline()函数.

如果我删除了getline(),那么produce(..)方法仍然会返回成功的结果.但是,我在kafka-console-consumer的命令窗口中看不到任何响应

我有点困惑.是对的吗？如何在不使用getline()的情况下发送消息？有谁知道？

我发现为什么它不起作用.删除生产者对象似乎太快,导致生产者无法向代理发送消息.

当我在Produ方法和删除生成器对象之间添加sleep 1000时,生产者可以正确地发送消息.

所以,问题是如何立即发送消息.在销毁生产者对象之前,如何确保完全发送这些消息？

如何解决这个问题,实际上我不喜欢在我的源代码中添加一些sleep().

win10 + vs2015 + kafka_2.10-0.9.0.1 + zookeeper-3.4.6 + librdkafka请查看以下代码

    // kafka_test_win32_nomfc.cpp 
//

#include "stdafx.h"
#include <iostream>
#include "librdkafka/rdkafkacpp.h"


int static producer_1()
{
    std::string brokers = "127.0.0.1";
    std::string errstr;
    std::string topic_str = "linli";
    std::string mode;
    std::string debug;
    int32_t partition = RdKafka::Topic::PARTITION_UA;
    int64_t start_offset = RdKafka::Topic::OFFSET_BEGINNING;
    bool do_conf_dump = false;
    int opt;
    // MyHashPartitionerCb hash_partitioner;
    int use_ccb = 0;

    /*
    * Create configuration objects
    */
    RdKafka::Conf *conf = RdKafka::Conf::create(RdKafka::Conf::CONF_GLOBAL);
    RdKafka::Conf *tconf = RdKafka::Conf::create(RdKafka::Conf::CONF_TOPIC);

    conf->set("metadata.broker.list", …