小编Iva*_*cki的帖子

当我发出消息时,我想从经纪人那里得到一些回应.我已经尝试过使用的CallBack机制(通过实现CallBack),KafkaProducer.send但它没有工作,也没有调用onCompletion方法.

当我关闭Kafka服务器并尝试生成消息时,它会调用回调方法.

有没有其他方式得到确认？

@Override
    public void onCompletion(RecordMetadata metadata, Exception exception) {
        long elapsedTime = System.currentTimeMillis() - startTime;
        System.out.println("Called Callback method");
        if (metadata != null) {
            System.out.println("message(" + key + ", " + message
                    + ") sent to partition(" + metadata.partition() + "), "
                    + "offset(" + metadata.offset() + ") in " + elapsedTime
                    + " ms");
        } else {
            exception.printStackTrace();
        }

    }

props.put("bootstrap.servers", "localhost:9092");
props.put("client.id", "mytopic");
props.put("key.serializer", org.apache.kafka.common.serialization.StringSerializer.class);
props.put("value.serializer", org.apache.kafka.common.serialization.ByteArraySerializer.class);

KafkaProducer<String, byte[]> producer = new KafkaProducer<String,byte[]>(props); …

我正在尝试在 ubuntu 的 python 2.7 中安装 requirements.txt 文件，但出现错误：

命令“python setup.py egg_info”在 /tmp/pip-install-YYFUnW/psycopg2/ 中失败，错误代码为 1

这究竟是什么意思，我该如何解决？我已经尝试过这些命令：

apt-get install python-bs4
sudo install --upgrade setuptools
sudo apt-get update

错误图像：

我正在接收来自JMS MQ队列的消息,这些消息应该被utf-8编码.然而,在阅读出来时,msgText = ((TextMessage)msg).getText(); 我得到了非标准字符存在的问号.在使用a时似乎可以指定编码bytemessage,但我无法在读出时找到指定编码的方法TextMessage.有没有办法解决这个问题,还是我应该按bytemessages？

将GoLand从EAP 18更新到EAP 19后,我的导入为红色,并且每个文件中都会出现以下错误:

我的$ GOROOT和$ GOPATH和以前一样.$ GOROOT指向/usr/local/go.文件可以通过shell构建,但GoLand会继续显示错误.

我正在使用Go版本 在Mac OS上运行GoLand go1.9.1 darwin/amd64:

GoLand(1.0预览版)1.0 EAP Build#GO-173.3727.24,建于2017年11月16日GoLand EAP用户有效期:2017年12月16日JRE:1.8.0_152-release-1024-b6 x86_64 JVM:OpenJDK 64位服务器VM by JetBrains sro Mac OS X 10.12.6

我分配了一个快捷键CMD+ SHIFT+L中键映射偏好（选择所有出现，就像它是在VSCode）。它与之前的任何键映射都没有冲突。但是，当我按下它时，所有出现的事件都会被选中，而且还会在另一个窗口中打开 Safari 谷歌搜索。

如何禁用此谷歌搜索快捷方式？未设置搜索 google 键映射。

我在 Windows 10 机器上安装了 Java 并下载了 Metabase.jar并运行它。

现在我可以在localhost:3000访问元数据库