我正在尝试启动kafka模式注册表,但收到以下错误:无法将Noop记录写入kafka商店.堆栈跟踪如下.我检查了与zookeeper,kafka经纪人的联系 - 一切都很好.我可以发信息到kafka.我试图删除_schema主题,甚至重新安装kafka,但这个问题仍然存在.昨天一切都工作正常,但今天,重新启动我的流浪盒后,这个问题出现了.我能做些什么吗？谢谢
[2015-11-19 19:12:25,904] INFO SchemaRegistryConfig values:
master.eligibility = true
port = 8081
kafkastore.timeout.ms = 500
kafkastore.init.timeout.ms = 60000
debug = false
kafkastore.zk.session.timeout.ms = 30000
request.logger.name = io.confluent.rest-utils.requests
metrics.sample.window.ms = 30000
schema.registry.zk.namespace = schema_registry
kafkastore.topic = _schemas
avro.compatibility.level = none
shutdown.graceful.ms = 1000
response.mediatype.preferred = [application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/json]
metrics.jmx.prefix = kafka.schema.registry
host.name = 12bac2a9529f
metric.reporters = []
kafkastore.commit.interval.ms = -1
kafkastore.connection.url = master.mesos:2181
metrics.num.samples = 2
response.mediatype.default = application/vnd.schemaregistry.v1+json
kafkastore.topic.replication.factor = 3
(io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig:135)
[2015-11-19 19:12:25,904] INFO SchemaRegistryConfig values:
master.eligibility …我有一个具有以下结构的文档：
user {id: 123, tag:"tag1"}
user {id: 123, tag:"tag2"}
user {id: 123, tag:"tag3"}
user {id: 456, tag:"tag1"}
给定用户 ID，我想查找此用户是否具有包含所有 3 个标签（AND 操作数）的记录。如果用户有“tag1”和“Tag2”和“tag3”的记录，则返回true
SQL 等效项如下所示：
SELECT * FROM users WHERE
EXISTS (SELECT * FROM tags WHERE user_id = users.id AND name ='tag1') AND
EXISTS (SELECT * FROM tags WHERE user_id = users.id AND name ='tag2') AND
user_id=123
如何在 MongoDB 中表达类似的东西？