小编cri*_*007的帖子

关于更改与kafka相关的一些属性并重新启动集群,我面临以下问题.

In kafka Consumer, there were 5 consumer jobs are running . 

如果我们进行了一些重要的属性更改,并且在重新启动集群时,部分/全部现有的使用者作业无法启动.

Ideally all the consumer jobs should start , 

因为它将从以下系统主题获取元数据信息.

config.storage.topic
offset.storage.topic
status.storage.topic

我研究了堆栈溢出的不同线程并做了一些研究，在建立 http 连接后，我无法在 java 中运行此代码。相同的命令在命令行中工作得很好

curl -X POST --header "Content-Type: application/json" --header "Accept: */*" -d "data" "http://a url"

我需要一个用于上述 curl 命令的 Java 代码，但我一直无法想出任何有价值的东西

我之前已经成功地将 pyspark 用于 Spark Streaming（Spark 2.0.2）和 Kafka（0.10.1.0），但我的目的更适合结构化流。我尝试在线使用示例：https : //spark.apache.org/docs/2.1.0/structured-streaming-kafka-integration.html

使用以下类似代码：

ds1 = spark
  .readStream
  .format("kafka")
  .option("kafka.bootstrap.servers", "host1:port1,host2:port2")
  .option("subscribe", "topic1")
  .load()
query = ds1
  .writeStream
  .outputMode('append')
  .format('console')
  .start()
query.awaitTermination() 

但是，我总是以以下错误告终：

: org.apache.kafka.common.config.ConfigException: 
Missing required configuration "partition.assignment.strategy" which has no default value

我还尝试在创建 ds1 时将其添加到我的选项集中：

.option("partition.assignment.strategy", "range")

但即使明确地为其分配一个值也不能阻止错误，我可以在网上或 Kafka 文档中找到的任何其他值（如“roundrobin”）也没有。

我也用“assign”选项尝试了这个并实现了同样的错误（我们的Kafka主机设置为assign——每个消费者只分配一个分区，我们没有任何重新平衡）。

知道这里发生了什么吗？该文档没有帮助（可能是因为它仍处于实验阶段）。另外，是否有使用 KafkaUtils 进行结构化流处理？或者这是唯一的网关？

我试图将链接存储在列表中，请遵循以下代码

public class frameswitch {

public static void main(String[] args) {

    System.setProperty("webdriver.gecko.driver","C:\\geckodriver\\geckodriver.exe");  
    WebDriver driver=new FirefoxDriver();
    String baseUrl="https://www.udacity.com/";
    driver.get(baseUrl);
    String Title="Udacity - Free Online Courses and Nanodegree Programs";
    List<WebElement> linkElements = driver.findElements(By.tagName("a"));
    }
}

但是在使用列表时面临错误

List类型不是通用的；无法使用参数<WebElement>类型对其进行参数化

我一直在尝试一种方法来获取我已经尝试过使用数组转换的前两个对象，并且也在迭代器中使用

每次我崩溃的时候

    String[] strArr = (String[])map.keySet().toArray();    //crash
    Integer[] integerArr = (Integer[])map.values().toArray();


    String string1 = strArr[0];
    int value1 = integerArr[0];


    String string2 = strArr[1];
    int value2 = integerArr[1];

我在String中有latlng值.我想将该String转换为LatLng对象.喜欢LatLng latlng = new LatLng(lat, lng);

这是我的数据:

String latlan =" 
    [[13.041695199971244, 77.61311285197735], 
    [13.042000923637021, 77.61313531547785], 
    [13.041830750574812, 77.61335827410221], 
    [13.041507062142946, 77.61269208043814]]
";

提前致谢

我知道您可以使用rstrip删除空白行，但是包含文本的行呢？

例如我的字符串输出是：

AAAA
BBBB
CCCC 
DDDD
FFFF

我想删除DDDD＆FFFF，所以输出可以是

AAAA
BBBB
CCCC

所以,我是使用Python和NLTK的新手.我有一个名为reviews.csv的文件,其中包含从亚马逊中提取的注释.我已将此csv文件的内容标记化并将其写入名为csvfile.csv的文件中.这是代码:

from nltk.tokenize import sent_tokenize, word_tokenize
from nltk.stem import PorterStemmer
import csv #CommaSpaceVariable
from nltk.corpus import stopwords
ps = PorterStemmer()
stop_words = set(stopwords.words("english"))
with open ('reviews.csv') as csvfile:
    readCSV = csv.reader(csvfile,delimiter='.')    
    for lines in readCSV:
        word1 = word_tokenize(str(lines))
        print(word1)
    with open('csvfile.csv','a') as file:
        for word in word1:
            file.write(word)
            file.write('\n')
    with open ('csvfile.csv') as csvfile:
        readCSV1 = csv.reader(csvfile)
    for w in readCSV1:
        if w not in stopwords:
            print(w)

我试图在csvfile.csv上执行词干.但我得到这个错误:

  Traceback (most recent call last):<br>
  File "/home/aarushi/test.py", line …

我不知道为什么echo $ JAVA_HOME返回空白

Abdelmajids-iMac:~ majid$ vi .profile

export PATH=/usr/local/bin:(...)
[[ -s "$HOME/.rvm/scripts/rvm" ]] && source "$HOME/.rvm/scripts/rvm" # Load 
RVM into a shell session *as a function*
export JAVA_HOME=$(/usr/libexec/java_home)
~                                                                                                    

~      


Abdelmajids-iMac:~ majid$ /usr/libexec/java_home
/Library/Java/JavaVirtualMachines/jdk1.8.0_151.jdk/Contents/Home
Abdelmajids-iMac:~ majid$ vi .bash_profile
Abdelmajids-iMac:~ majid$ source .bash_profile
-bash: .bash_profile: line 1: syntax error near unexpected token `('
-bash: .bash_profile: line 1: `export PATH=/usr/local/bin:(...)'
Abdelmajids-iMac:~ majid$ echo  $JAVA_HOME

Abdelmajids-iMac:~ majid$ 

我正在使用 Kafka 使多个微服务相互通信。服务是用 Python 编写的，我使用 Confluent 库来处理 Kafka。在某些时候，我知道某些主题刚刚“结束”，因此我可以自动清理它们。

由于 Confluent 库，有没有办法删除“主题”？我找不到任何关于此的文档...

谢谢