小编Avi*_*ash的帖子

我是Kafka的新手,我创建了一个名为的主题 Hell0-Kafka3

现在我想删除它.所以我发出这样的命令:

$ bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic Hello-Kafka3
Topic Hello-Kafka3 is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.

有人可以帮我理解注意:在最后一行？

要在AWS中从2节点集群中删除节点,我运行了

nodetool removenode <Host ID>

此后,我应该让我的集群回来,如果我把所有的cassandra.yaml和cassandra-rackdc.properties正确的.我做了但仍然,我无法恢复我的群集.

nodetool status 只显示一个节点.

cassandra上的重要system.log是:

INFO  [main] 2017-08-14 13:03:46,409 StorageService.java:553 - Cassandra version: 3.9
INFO  [main] 2017-08-14 13:03:46,409 StorageService.java:554 - Thrift API version: 20.1.0
INFO  [main] 2017-08-14 13:03:46,409 StorageService.java:555 - CQL supported versions: 3.4.2 (default: 3.4.2)
INFO  [main] 2017-08-14 13:03:46,445 IndexSummaryManager.java:85 - Initializing index summary manager with a memory pool size of 198 MB and a resize interval of 60 minutes
INFO  [main] 2017-08-14 13:03:46,459 MessagingService.java:570 - Starting Messaging Service on …

我有 au 用户，其密码中包含特殊字符。密码是123@456。我试图逃避这个角色，但仍然不起作用。下面是我尝试过的方法：

$ mongo mongodb://user5:123%40456@localhost:28017/admin
MongoDB shell version v3.4.0
connecting to: mongodb://user5:123%40456@localhost:28017/admin
2017-02-14T12:11:47.571+1100 E QUERY    [main] Error: Authentication failed. :
connect@src/mongo/shell/mongo.js:234:13
@(connect):1:6
exception: connect failed

我可以使用以下方式进行连接：

$ mongo mongodb://localhost:28017/admin -u user5 -p 123@456
MongoDB shell version v3.4.0
connecting to: mongodb://localhost:28017/admin
MongoDB server version: 3.4.0

但我正在寻找一种通过 URI 进行连接的方法。如何@在 MongoDB 中使用该字符作为 URI 连接中的密码？这样，我可以使用相同的 URI 进行 shell 连接和驱动程序连接。

在生产服务器上，我被迫使用 python3.2。可悲的是，我的几个依赖项需要>=python3.4. 有没有办法找出可以与特定 python 版本一起使用的包的最新版本？

例如， with python3.2，numpy应该使用什么版本？

（这只是一个例子，理想情况下答案不会集中在例子上，而是在实际问题上）。

我正在使用 kafka、zookeeper 和 kafka-manager 来管理集群。

我有 3 个节点集群。在我从一开始就设置的所有集群中delete.topic.enable=true

现在，当我想删除一个主题时，它显示以下错误。

topicxyz - marked for deletion

但它没有被删除。

我也尝试从 kafka-manager 中删除，它说

Yikes! KeeperErrorCode = NodeExists for /admin/delete_topics/topicxyz

错误日志：

卡夫卡经理：

[ESC[31merrorESC[0m] k.m.ApiError$ - error : KeeperErrorCode = NodeExists for /admin/delete_topics/topicxyz
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists for /admin/delete_topics/topicxyz
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:119) ~[org.apache.zookeeper.zookeeper-3.4.6.jar:3.4.6-1569965]
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) ~[org.apache.zookeeper.zookeeper-3.4.6.jar:3.4.6-1569965]
        at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783) ~[org.apache.zookeeper.zookeeper-3.4.6.jar:3.4.6-1569965]
        at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:721) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
        at org.apache.curator.framework.imps.CreateBuilderImpl$11.call(CreateBuilderImpl.java:704) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
        at org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:108) ~[org.apache.curator.curator-client-2.10.0.jar:na]
        at org.apache.curator.framework.imps.CreateBuilderImpl.pathInForeground(CreateBuilderImpl.java:701) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
        at org.apache.curator.framework.imps.CreateBuilderImpl.protectedPathInForeground(CreateBuilderImpl.java:477) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
        at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:467) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
        at org.apache.curator.framework.imps.CreateBuilderImpl.forPath(CreateBuilderImpl.java:447) ~[org.apache.curator.curator-framework-2.10.0.jar:na]
[ESC[37minfoESC[0m] k.m.a.KafkaManagerActor - Updating internal state... …

我正在尝试使用 kafka，MultiProcessConsumer但出现以下错误。似乎错误与python中的多线程有关

这是我正在使用的代码。

simple.py

from kafka import SimpleProducer, SimpleClient, SimpleConsumer, MultiProcessConsumer

# To consume messages
client = SimpleClient('localhost:9092')
consumer = MultiProcessConsumer(client, "my-group", "testing_topic", num_procs=3)
for message in consumer:
    # message is raw byte string -- decode if necessary!
    # e.g., for unicode: `message.decode('utf-8')`
    print(message)

client.close()

运行上述代码时出错。

$ python simple.py 
Error in atexit._run_exitfuncs:
Traceback (most recent call last):
  File "/var/users/ec2-user/.pyenv/versions/3.6.0/lib/python3.6/multiprocessing/managers.py", line 749, in _callmethod
    conn = self._tls.connection
AttributeError: 'ForkAwareLocal' object has no attribute 'connection'

During handling of the above …

我是 vuejs 的新手，我收到以下错误：错误：

[Vue warn]: Failed to mount component: template or render function not defined.

found in

---> <Anonymous>
       <Vcinfo> at resources/assets/js/valuechain/Vcinfo.vue
         <Root>

Vcinfo.vue

<template>
    <div id="root">
        <div class="navbar navbar-default">
            <div class="navbar-brand">
                <router-link to="/vc">VALUECHAIN</router-link>
            </div>
            <ul class="nav navbar-nav navbar-left">
                <li><router-link to="/vc/setting_keywords">Keywords Setting</router-link></li>
                <li><router-link to="/vc/keyword_search">Search Keywords</router-link></li>
            </ul>
        </div>
        <router-view></router-view>
    </div>
</template>

<style lang="css">
    .navbar {
        margin-top:15px;
    }
</style>

vc.js

import Vue from 'vue'
import Vcinfo from './Vcinfo.vue'
import router from './router'

const app = new Vue({
    el: '#vc',
    components: { Vcinfo …

vuejs我想使用和转到特定选项卡element-ui。这是 jsfiddle 文件。https://jsfiddle.net/hutsu1zf/10/

默认情况下它会降落到第一个选项卡。在页面加载事件时如何登陆任何其他选项卡。我是 vuejs 新手，所以即使有一些提示也将不胜感激。

Python词典具有key独特性.但我正在努力编写(找到)支持以下内容的DS:

例1:

|------|-----------------|
| abc  | matched in abcD |
|------|-----------------|
| match| matched in abcD |
|------|-----------------|
| abc  | abc found again |

如果下一个条目如下:

|-----|-----------------|                     
| abcd| matched in abcD |  ----> should replace first entry because abc is substring of abcd.

所以条目/表应该是这样的

|------|-----------------|
| abcd | matched in abcD |
|------|-----------------|
| match| matched in abcD |
|------|-----------------|
| abc  | abc found again | 

有什么建议 ？

可能的功能定义

def substring_value_confirm(keys, values):
    # implement as …

我试图找到下面代码的复杂性,因为for循环它将是O(n*complexity_of_map.merge)

public int solution(int K, int[] A) {    
    Map<Integer, Integer> map = new HashMap<Integer, Integer>();
    for(int i =0; i < A.length; i++){
        map.merge(K - A[i], 1, Integer::sum);
    }   
    return Arrays.stream(A).map(element -> map.getOrDefault(element,0)).sum();
} 

有人可以帮我理解上面代码和map.merge() Java 8中的时间复杂度.