小编Raj*_*Raj的帖子

我试图避免在执行“ git status”命令时显示不需要的文件夹内容（例如：.settings，.metadata等）。我在添加文件夹名称之后修改了.gitignore文件，但是当我执行git status时，仍然得到所有这些文件。

请帮我。

我试图了解“compression.type”配置，我的问题是，如果我在主题级别和生产者级别设置“compression.type”，哪个优先？

我试图了解 ConsumerConfig.auto.offset.reset = latest 如何影响消息消耗。

例如，我有一个消费者，最初在 t1 时间发送 100 条消息，然后我的消费者在 t1+30 秒启动并运行，然后我的消费者会消费 t1+30 秒后发布的消息还是会消费 t1 之后发布的消息?

我试图了解以下两个融合消费者配置的默认值如何协同工作。

max.poll.interval.ms - 根据汇合文档，默认值为 300,000 毫秒

session.timeout.ms - 根据汇合文档，默认值为 10,000 毫秒

heartbeat.interval.ms - 根据汇合文档，默认值为 3,000 毫秒

假设我在配置中使用这些默认值。现在我有一个问题。

例如，假设消费者每 3,000 毫秒发送一次心跳，我的第一次轮询发生在时间戳 t1，然后第二次轮询发生在 t1 + 20,00 毫秒。那么它会因为超过“session.timeout.ms”而导致重新平衡吗？或者当消费者确实按照预期时间戳发送心跳时，它会正常工作吗？

我想了解什么时候应该使用 org.springframework.retry.RecoveryCallback 和 org.springframework.kafka.listener.KafkaListenerErrorHandler？

截至今天，我正在使用一个类（实现 org.springframework.retry.RecoveryCallback）来记录错误消息并将消息发送到 DLT，它正在工作。为了向 DLT 发送消息，我使用了 Spring KafkaTemplate，然后遇到了 KafkaListenerErrorHandler 和 DeadLetterPublishingRecoverer。现在，你能建议我，我应该如何使用 KafkaListenerErrorHandler 和 DeadLetterPublishingRecoverer 吗？这可以替代 RecoveryCallback 吗？

这是我当前的 kafkaListenerContainerFactory 代码

@Bean
public ConcurrentKafkaListenerContainerFactory kafkaListenerContainerFactory() {

ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();

factory.setConsumerFactory(primaryConsumerFactory());
factory.setRetryTemplate(retryTemplate());
factory.setRecoveryCallback(recoveryCallback);
factory.getContainerProperties().setAckMode(AckMode.RECORD);
factory.setConcurrency(1);  
factory.getContainerProperties().setMissingTopicsFatal(false);
return factory;   }

Run Code Online (Sandbox Code Playgroud)

我试图了解在 kafka 消费者中处理需要更长时间处理的记录的更好选择是什么？我进行了一些测试来理解这一点，并观察到我们可以通过修改max.poll.records或来控制这一点max.poll.interval.ms。

现在我的问题是，什么是更好的选择？请建议。

我想了解 Kafka 多久轮换一次分区领导者？我们有什么财产可以控制它吗？

在 Spring 启动应用程序中为 kafka 使用者设置重试策略时，何时使用 ExponentialBackOffPolicy 与 FixedBackOffPolicy？

我将FixedBackOffPolicy视为BackOffPolicy 的一种实现，它在继续之前暂停一段固定的时间，而ExponentialBackOffPolicy 则视为 BackOffPolicy 的一种实现，它增加了给定集中每次重试尝试的回退时间。

除此之外， FixedBackOffPolicy 扩展了 StatelessBackOffPolicy 而 ExponentialBackOffPolicy 没有。在这方面，请帮助我理解，什么是更喜欢一个而不是另一个的合适用例？

我们使用 spring boot 2.1.7.RELEASE 和 spring-kafka 2.2.7.RELEASE。现在，我们计划将 spring-kafka 版本更新到 2.4.0.RELEASE，并在应用程序启动时出现以下错误

java.lang.ClassNotFoundException: org.springframework.core.log.LogAccessor

你能建议我在这里缺少什么吗？