小编use*_*exp的帖子

Spring Kafka 不尊重 max.poll.records 的奇怪行为

好吧,我正在尝试以下场景:

  1. 在 application.properties 中将 max.poll.records 设置为 50。
  2. 在 application.properties 中设置 enable-auto-commit=false 和 ack-mode 为手动。
  3. 在我的方法中添加了@KafkaListener,但不提交任何消息,只是读取、记录但不做出ACK。

实际上,在我的 Kafka 主题中,我有 500 条消息要使用,所以我期望出现以下行为:

  1. Spring Kafka poll() 50 条消息(偏移量 0 到 50)。
  2. 正如我所说,我没有提交任何内容,只是记录了 50 条消息。
  3. 在下一次 Spring Kafka poll() 调用中,获取与步骤 1 相同的 50 条消息(偏移量 0 到 50)。根据我的理解,Spring Kafka 应该继续此循环(步骤 1-3),始终读取相同的消息。

但发生的情况如下:

  1. Spring Kafka poll() 50 条消息(偏移量 0 到 50)。
  2. 正如我所说,我没有提交任何内容,只是记录了 50 条消息。
  3. 在下一次 Spring Kafka poll() 调用中,获取下 50 条消息,与步骤 1 不同(偏移 50 到 100)。

Spring Kafka 以 50 条消息为一组读取 500 条消息,但不提交任何内容。如果我关闭应用程序并重新启动,则会再次收到 500 …

spring apache-kafka spring-kafka

7
推荐指数
1
解决办法
7395
查看次数

带有 Powerlevel10k 的 ZSH 在终端启动时不起作用

我使用的是 Fedora 31,并安装了带有 PowerLevel10k 的 ZSH (Oh-my-zsh)。当我打开 gnome-terminal 时,正如我所料,我将 ZSH 作为默认 shell。但是当我输入以下内容时,Powerlevel10k 才被加载:source ~/.zshrc

这是我的 zshrc 文件内容:

plugins=(git)
source $ZSH/oh-my-zsh.sh
ZSH_THEME=powerlevel10k/powerlevel10k

# To customize prompt, run `p10k configure` or edit ~/.p10k.zsh.
[[ ! -f ~/.p10k.zsh ]] || source ~/.p10k.zsh
"~/.zshrc" 110L, 4104C  
Run Code Online (Sandbox Code Playgroud)

另一件重要的事情是,每次我输入 时source ~/.zshrc,我都会收到以下错误,但使用 Powerlevel10k 一切正常:

[ERROR]: When using instant prompt, Powerlevel10k must be loaded before the first prompt.
Run Code Online (Sandbox Code Playgroud)

zsh oh-my-zsh

6
推荐指数
1
解决办法
1万
查看次数

标签 统计

apache-kafka ×1

oh-my-zsh ×1

spring ×1

spring-kafka ×1

zsh ×1