小编cla*_*smc的帖子

使用Vertx记录关联ID

我想在我的日志中添加一个关联ID,以便我可以跟踪不同服务器之间的呼叫.但是我使用Vert.x并且不能使用MDC或ThreadLocal.有任何想法吗?

java logging vert.x

7
推荐指数
0
解决办法
946
查看次数

Autowired 字段上的 PMD 异常 BeanMembersShouldSerialize

我在自动装配字段上收到诸如“BeanMembersShouldSerialize”之类的 PMD 异常。阻止它们的唯一方法是使用“transient”或@SuppressWarnings。我的问题是处理 PMD 和自动连线字段的正确方法是什么。

@Component
public class Sample {

@Autowired
private SoapProperties soapProperties;

public void doSomething() {
    // do something
}
Run Code Online (Sandbox Code Playgroud)

Sample.java:13:找到非瞬态、非静态成员。请标记为瞬态或提供访问器。

java spring pmd autowired

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

Jenkins 和更新 git 子模块

我正在使用 Jenkins“高级子模块行为”并检查了“递归更新子模块”选项。但是我只在旧版本中获得子模块。我希望始终拥有子模块的主要修订版。我在“高级子模块行为”中找到了另一个选项,称为“将跟踪子模块更新到分支尖端”。这似乎使用了 --remote 选项。这会解决问题吗?

有任何想法吗?

git git-submodules jenkins jenkins-plugins

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

seekToEnd 所有分区并在 Kafka 消费者的自动重新平衡中幸存下来

当消费者组 A 的 Kafka 消费者连接到 Kafka 代理时,我想寻找所有分区的末尾,即使在代理端存储了偏移量。如果更多额外的消费者连接到同一个消费者组,他们应该获取最新存储的偏移量。我正在做以下事情:

consumer.poll(timeout) 
consumer.seekToEnd(emptyList())

while(true) {
  val records = consumer.poll(timeout)
  if(records.isNotEmpty()) {
    //print records
    consumer.commitSync()
  }
}
Run Code Online (Sandbox Code Playgroud)

问题是当我连接消费者组 A 的第一个消费者 c1 时,一切都按预期工作,如果我连接消费者组 A 的额外消费者 c2,则该组正在重新平衡,并且 c1 将消耗跳过的偏移量。

有任何想法吗?

java kotlin apache-kafka

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