小编swa*_*il7的帖子

消费者“group_name”组正在永远重新平衡

我使用的是卡夫卡:2.11-1.0.1。该应用程序包含主题“X”的并发度为 5 且分区为 5 的使用者。

当应用程序重新启动并且在分区分配之前在主题“X”上发布消息时,主题“X”的 5 个消费者找到组协调器并向组协调器发送加入组请求。预计会得到团体协调员的答复,但没有收到任何答复。

我已检查 Kafka 服务器日志,但找不到 DEBUG 日志级别的相关日志。

当我运行描述消费者组命令时,出现以下观察结果:

  1. 消费群体正在重新平衡
  2. 老消费者,有一定滞后性
  3. 具有一些随机名称的新消费者。随着时间的推移,新的消费者数量不断增加。

新消息发布在主题“X”上,但消费者没有收到。

heartbeat 和 session.time.out 设置为默认值。

如果消息在主题“X”及其使用者的分区分配之前发布,则会出现此问题。

我的疑问是:为什么重新平衡没有完成以便新的消费者开始消费新生成的消息?

apache-kafka kafka-consumer-api rebalancing spring-kafka

6
推荐指数
1
解决办法
1万
查看次数

生成n个随机数,其总和为m,所有数字应大于零

我想生成9个非零随机数,其总和是250.我试过下面的代码,它给了我9个随机数,但有些数字为零.

 public void n_random()
{
  Random r = new Random();
ArrayList<Integer> load = new ArrayList<Integer>();
    int temp = 0;
    int sum = 0;
    for (int i = 1; i <= 9; i++) {
        if (!(i == 9)) {
            temp = r.nextInt(250 - sum);
            System.out.println("Temp " + (i) + "    " + temp);
            load.add(temp);
            sum += temp;

        } else {
            int last = (250 - sum);
            load.add(last);
            sum += last;
        }
    }

    System.out.println("Random arraylist " + load);
    System.out.println("Sum is "+ sum); …
Run Code Online (Sandbox Code Playgroud)

java random

5
推荐指数
2
解决办法
6700
查看次数

如何在AWS中处理大型WAR文件?

我做了什么 ?

使用JSP开发Web应用程序,允许用户注册,登录和上传文件到AWS S3.我通过上传应用程序的war文件,使用Elastic Beanstalk将此应用程序部署到aws.对于登录和注册模块,我使用过RDS,它工作正常.

问题

当我想将文件上传到S3时,我需要在WEB应用程序中使用AWS SDK jar及其支持的JAR文件.当我完成开发部分并导出war文件时,它大约是75 MB.所以问题是,如果我将任何内容更改为app,我需要将此大型战争上传到aws.由于AWS SDK的JAR文件,war文件的大小受到影响.

处理这种情况有哪些选择?

java amazon-s3 amazon-web-services amazon-elastic-beanstalk

5
推荐指数
1
解决办法
674
查看次数

SPARQL的正则表达式

我从dbpedia下载了dbpedia_quotationsbook.zip,其中包含dbpedia_quotationsbook.nt triplestore.

在这个三元店

subject是authorname
谓词是"sameas"
对象是authorcode

我使用JENA尝试了这个查询三元组,简单的查询正在运行.

现在我想要所有的authorcode,其authorname与给定的字符串部分匹配.所以我尝试了以下查询

select ?code
where
{

FILTER regex(?name, "^Rob")  <http://www.w3.org/2002/07/owl#sameAs> ?code.

}
Run Code Online (Sandbox Code Playgroud)

上面的查询应返回其authorname包含"Rob"的所有authorcodes

我得到以下异常

Exception in thread "main" com.hp.hpl.jena.query.QueryParseException: Encountered " "." ". "" at line 5, column 74.
Was expecting one of:
    <IRIref> ...
    <PNAME_NS> ...
    <PNAME_LN> ...
    <BLANK_NODE_LABEL> ...
    <VAR1> ...
    <VAR2> ...
    "true" ...
    "false" ...
    <INTEGER> ...
    <DECIMAL> ...
    <DOUBLE> ...
    <INTEGER_POSITIVE> ...
    <DECIMAL_POSITIVE> ...
    <DOUBLE_POSITIVE> ...
    <INTEGER_NEGATIVE> ...
    <DECIMAL_NEGATIVE> ...
    <DOUBLE_NEGATIVE> ...
    <STRING_LITERAL1> ...
    <STRING_LITERAL2> …
Run Code Online (Sandbox Code Playgroud)

java rdf sparql apache-jena

1
推荐指数
1
解决办法
977
查看次数