我需要从 io.confluence:kafka-schema-registry:5.3.0 中排除 slf4j 依赖项。我尝试过使用
implementation ('io.confluent:kafka-schema-registry:5.3.0') {
exclude(group='org.slf4j',module='slf4j-loh4j12')
}
但我不断收到错误
Cannot set the value of read-only property 'group' for DefaultExternalModuleDependency{group='io.confluent', name='kafka-schema-registry', version='5.3.0', configuration='default'} of type org.gradle.api.internal.artifacts.dependencies.DefaultExternalModuleDependency.
谁能告诉我如何实现这一目标。我尝试了多种方法但无法做到
我一直读到Kafka只将一个消费者实例（线程）分配给一个分区。我最近遇到了ConcurrentKafkaListenerContainerFactory并正在阅读它，有些方面似乎与我之前所知道的相矛盾。
假设我们有一个消费者实例（pod/机器），在其中我使用ConcurrentKafkaListenerContainerFactory ，并发级别设置为 3 3。我有一个包含三个分区的 Kafka 主题。将并发级别设置为三时，我知道我的@KafkaListener 方法将从主题的所有三个分区读取消息。
这是否意味着即使只有一个消费者实例，我们也能够并行消费来自三个分区的消息。
这可以作为替代方案来提高 Kafka 主题的消费率而不增加分区数量吗？我知道的唯一其他方法是创建一个线程池并将收到的消息提交给它。我们可以使用 ConcurrentKafkaListenerContainerFactory 作为此过程的替代品吗，因为这听起来确实更容易实现。