-
0 votesanswersviews
元数据响应 - 代理主机名错误
我使用python-kafka的SimpleConsumer来收听kafka经纪人的话题 . Kafka代理正在一台主机名为BROKER_HOST的机器上运行 . 现在,SimpleConsumer从代理BROKER_HOST请求主题元数据以获取主题TOPIC并获取元组 (Broker metadata, Topic metadata) 经纪人元数据来自, {0: BrokerMetadata... -
2 votesanswersviews
当使用websocket连接时,使用akka-stream-kafka从kafka主题获取最后一条消息
是否可以使用Akka Streams Kafka在Kafka主题上获取最后一条消息?我正在创建一个侦听Kafka主题的websocket,但是当我连接时它会检索所有先前的unred消息 . 这可以添加相当多的消息,所以我只对最后消息中的任何未来消息感兴趣 . (或仅限未来的消息) 来源: def source(): Flow[Any, String, NotUsed] = { val sou... -
0 votesanswersviews
Lagom Kafka客户端集成问题
我正在研究lagom并尝试连接到非Lagom Java环境中的Lagom服务提供的主题 . 我使用以下方式订阅了该主题: LagomClientFactory clientFactory = LagomClientFactory.create("legacy-system",LagomClientFactory.class.getClassLoader()); Ticketi... -
1 votesanswersviews
AVRO架构更新的麻烦
我有一个简单的案例类: case class User(id: String, login: String, key: String) 我添加字段“名称” case class User(id: String, login: String, name: String, key: String) 然后在avro架构中添加此字段(user.avsc) { "namespace&quo...