#java #spring #apache-kafka #kafka-consumer-api
Вопрос:
Я использую spring cloud stream @StreamListener для приема сообщений. Мой производитель отправит 100 сообщений за 1 минуту, но мой потребитель потребляет только 400 сообщений за 1 минуту, после этого я обрабатываю операцию вставки БД, это вызов внешней службы. Нужно ли мне увеличивать количество экземпляров для потребителей? Я хочу ускорить свой потребительский процесс.
allow.auto.create.topics = true
auto.commit.interval.ms = 100
auto.offset.reset = latest
bootstrap.servers = [localhost:9092]
check.crcs = true
client.dns.lookup = default
client.id =
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = anonymous.6d18aa50-c818-4f5e-ad75-ff8164961307
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
isolation.level = read_uncommitted
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 500
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000