我想在我的日志中添加一个关联ID,以便我可以跟踪不同服务器之间的呼叫.但是我使用Vert.x并且不能使用MDC或ThreadLocal.有任何想法吗?
我在自动装配字段上收到诸如“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:找到非瞬态、非静态成员。请标记为瞬态或提供访问器。
我正在使用 Jenkins“高级子模块行为”并检查了“递归更新子模块”选项。但是我只在旧版本中获得子模块。我希望始终拥有子模块的主要修订版。我在“高级子模块行为”中找到了另一个选项,称为“将跟踪子模块更新到分支尖端”。这似乎使用了 --remote 选项。这会解决问题吗?
有任何想法吗?
当消费者组 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 将消耗跳过的偏移量。
有任何想法吗?