小编use*_*024的帖子

Log4j2 左填充文件名带零

有没有办法在log4j的滚动文件附加器中用零填充?

例如 myfile-00001.txt

我正在使用第 3 方日志处理器,它按字典顺序读取文件,因此必须对文件进行填充...

我在 log4j 的 filePattern 中添加了以下内容,但我得到了空格。

${logPath}/myfile-%05i.txt

java logging log4j log4j2

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

如何保证Kafka分区的订单

好的,我明白你每个分区只能获得订单保证.

只是随意的想法/问题.

假设分区策略正确并且消息正确分组到正确的分区(或者甚至说我们使用的是1分区)

我认为生产应用程序必须将每条消息1发送1到kafka,并确保在发送下一条消息之前已经确认每条消息都已被确认?

apache-kafka kafka-producer-api

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

如何加入多个Kafka主题?

所以我有...

  • 第一个具有通用应用程序日志(log4j)的主题。存储诸如HTTP API请求/响应和警告,异常等之类的东西。一个逻辑业务请求可以有多个日志关联。(这些日志在几秒钟之内发生)
  • 第二个主题包含来自上述业务请求的命令,其他服务将对其执行操作。(这些命令也会在几秒钟之内发生,但可能距原始请求只有几分钟的时间)
  • 第三个主题包含由其他服务的操作生成的事件。(大多数事件会在几秒钟内完成,但有些事件最多可能需要3-5天才能收到)

因此,单个逻辑业务请求可以具有由微服务彼此传递的uuid关联的多个日志,命令和事件。

那么,可以用来阅读这3个主题并将它们全部组合为一个json文档,然后将它们转储给Elasticsearch的技术/模式有哪些?

流媒体?

apache-kafka apache-kafka-streams ksql

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

测试 Kafka HA 并获取 NetworkException:服务器在收到响应之前已断开连接

运行 Confluence Kafka 4.1.1 社区。

我有...

  • 最小同步副本 = 2
  • 主题:1 个分区,副本数 3
  • 共有 3 名经纪人。
  • 生产者设置为 acks = -1
  • 所有其他生产者设置均为默认设置。

我启动了我的应用程序,当它开始向 Kafka 写入记录时,我故意关闭了其中一个代理,我立即得到:org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.

根据上面的设置。生产者 write() 不应该成功并且不抛出错误吗?

澄清

  • 我故意杀死经纪人
  • 这似乎只有在领导经纪人被杀时才会发生?

apache-kafka

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

如何将 Apache Flink 与查找数据一起使用?

.

你好,

使用 Apache Flink 1.8。我有一个来自 Kafka 的记录流作为 JSON 并过滤它们,一切正常。

现在,我想用数据库表中的查找值来丰富来自 Kafka 的数据。

这只是创建 2 个流,在第二个流中加载表然后加入数据的情况吗?

数据库表确实会更新但不经常更新,我想避免在通过流的每条记录上查找数据库。

apache-flink

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

Java Xmx 和 Docker 容器 RAM 大小之间还有多少余量?

我 100% 了解 JVM 的陷阱以及在 JVM 世界中为了解容器的人体工程学/资源而取得的进步/进步。另外,是的,我知道 Java 在默认情况下会尝试分配它运行的环境中可用 RAM 的 1/4...

所以我有一些想法和问题。我制定了 50/50 规则。如果我的应用程序需要 1GB 的 Xmx,那么我创建了 2GB 的容器,它为 JVM 开销和任何容器/交换的东西提供了另外 1GB 的 RAM(虽然不确定交换在容器中是如何真正工作的)。

所以我在想,如果我的应用程序需要 6GB 的 Xmx,我真的需要创建 12GB 的容器还是可以使用 7GB 或 8GB 的​​容器?当涉及到 RAM 时,我们需要在容器内部留出多少空间?

java containers docker java-heap

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

Netty客户端限制了队列丢弃策略

遇到连接到第三方服务器的OutMemoryError,它无法足够快地处理请求.

尝试使用有界队列和丢弃策略(ThreadPoolExecutor.DiscardPolicy)传递NioClientSocketChannelFactory以执行服务器,但仍然得到OutOfMemoryError.

我错过了什么?

谢谢

netty

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

Aerospike数据建模和查询

可以说我在JAVA中有以下模型

class Shape {
    String type;
    String color;
    String size;
}
Run Code Online (Sandbox Code Playgroud)

并说我有以下基于上述模型的数据.

Triangle, Blue, Small
Triangle, Red, Large
Circle, Blue, Small
Circle, Blue, Medium
Square, Green, Medium
Star, Blue, Large
Run Code Online (Sandbox Code Playgroud)

我想回答以下问题

Given the type Circle how many unique colors?
    Answer: 1
Given the type Circle how many unique sizes?
    Answer: 2

Given the color Blue how many unique shapes?
    Answer: 2
Given the color Blue how many unique sizes?
    Answer: 3

Given the size Small how many unique shapes?
    Answer: …
Run Code Online (Sandbox Code Playgroud)

data-modeling nosql aerospike

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

Gitlab docker 和 external_url

您好,我使用 docker 安装了最新的 gitlab。我用 -p 10080:80 和 10022:22 启动了容器

我可以浏览 gitlab 并做我需要做的事情,我什至可以分别使用端口 10080 和 10022 git clone http 和 ssh。

在前端,虽然 url 没有显示适当的端口。

我更改了 ssh_shell 属性。这很好用!

无论出于何种原因,任何修改 external_url 属性的尝试都不起作用!我放了“ http://myhost:10080 ”但是当我重新启动容器时,它似乎不想启动。我无法浏览任何内容,只需将其注释掉即可再次运行。

所以现在前端显示正确的 ssh 克隆 url,但不是 http 一个。

gitlab docker

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

是否有SolrJ查询构建器?

使用solr 5.2.0想知道是否存在类似于Elasticsearch查询构建器API的查询构建器API/Jar/Ckient,或者我们是否必须在Solr中使用String Kungfu来构建查询?

solr solrj solr-query-syntax solrcloud solr5

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