小编Mil*_*lan的帖子

我使用以下docker-compose.yml运行了本地kafka

version: '2'
services:
  zookeeper:
    image: "confluentinc/cp-zookeeper:5.0.1"
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000

  kafka:
    image: "confluentinc/cp-enterprise-kafka:5.0.1"
    ports:
      - '9092:9092'
    depends_on:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
      KAFKA_METRIC_REPORTERS: io.confluent.metrics.reporter.ConfluentMetricsReporter
      KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 100

尝试在Scala中使用kafka-client 2.1.0运行基本的创建主题：

val props = new Properties()
props.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")

val adminClient: AdminClient = AdminClient.create(props)
val newTopic = new NewTopic("test", 1, 1.toShort)
val topicsF = adminClient.createTopics(List(newTopic).asJavaCollection)
val result = topicsF.all().get()

但一段时间后，我得到：

org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

我可以使用命令行创建主题：

kafka-topics --create \
    --zookeeper localhost:2181 …

我已经设法训练了一个带有张量流的word2vec,我想将这些结果反馈到一个带有lstm细胞的rnn中进行序列标记.

1)如何将训练有素的word2vec模型用于rnn并不是很清楚.(如何提供结果？)

2)我没有找到关于如何实现序列标记lstm的文档.(我如何带上我的标签？)

有人能指出我如何开始这项任务的正确方向吗？

我想开始在 Eclipse 中编写 JADE。为此，我添加了Java 代理开发框架 - Eclipse 和 Maven 集成提供的以下脚本。

我做了一个代理：

public class Test extends Agent {

    private static final long serialVersionUID = 1L;

    String nickname = "Peter";
    AID id = new AID(nickname, AID.ISLOCALNAME);


    protected void setup() {
        // Printout a welcome message
        System.out.println("Hello! Buyer-agent " +getAID().getName()+ " is ready.");
    }
}

当我使用以下参数运行 JadeBootThread.run() 时：

private final String ACTOR_NAMES_args = "buyer:test.Test";

private final String GUI_args = "-gui";

我收到以下错误：

public class Test extends Agent {

    private static final long …