小编bin*_*nit的帖子

我的问题很简单但令人费解.可能有一个简单的开关可以解决这个问题,但我对Java正则表达不太熟悉......

String line = "";
line.replaceAll("(?i)(.)\\1{2,}", "$1");

这崩溃了.如果我取下(?i)开关,它就可以了.三个unicode字符不是随机的,它们是在韩文大文中发现的,但我不知道它们是否有效.

奇怪的是,正则表达式适用于所有其他文本,但这一点.为什么我会收到错误？

这是我得到的例外

Exception in thread "main" java.lang.StringIndexOutOfBoundsException: String index out of range: 6
    at java.lang.String.charAt(String.java:658)
    at java.lang.Character.codePointAt(Character.java:4668)
    at java.util.regex.Pattern$CIBackRef.match(Pattern.java:4846)
    at java.util.regex.Pattern$Curly.match(Pattern.java:4125)
    at java.util.regex.Pattern$GroupTail.match(Pattern.java:4615)
    at java.util.regex.Pattern$CharProperty.match(Pattern.java:3694)
    at java.util.regex.Pattern$GroupHead.match(Pattern.java:4556)
    at java.util.regex.Pattern$Start.match(Pattern.java:3408)
    at java.util.regex.Matcher.search(Matcher.java:1199)
    at java.util.regex.Matcher.find(Matcher.java:592)
    at java.util.regex.Matcher.replaceAll(Matcher.java:902)
    at java.lang.String.replaceAll(String.java:2162)
    at tokenizer.Test.main(Test.java:51)

我正处于探索Kafka版本0.8.1.1的初始阶段.

我已成功运行消费者组示例,其中包含多个分区及其在消费者中的分发消息.

我想运行的一个测试用例是当组中的消费者突然死亡时(例如,kill -9).当我这样做时,我预计会发生再平衡,但它没有发生.那么,我可以做其中一件事吗？

1. 使用API​​触发重新平衡
2. 将kafka配置为等待消费者活动的特定时间并自动重新平衡,假设它被非正常关闭.

这里的问题是,分配给死消费者的分区中的所有消息都保留在队列中,并且在重新平衡发生之前永远不会被处理.