Kafka Streams: Inconsistent Results with KStream-KTable Join Under Load

Hello, I'm developing a Quarkus microservice that utilizes Kafka Streams to process messages from multiple topics. Specifically, I'm attempting to join a KStream and a KTable derived from two of these topics. Under normal conditions, the join operates as expected. However, under increased load, th

[jira] [Resolved] (KAFKA-18381) Remove raftSupport in KafkaApisTest

[ https://issues.apache.org/jira/browse/KAFKA-18381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18381. --- Resolution: Duplicate > Remove raftSupport in KafkaApisTest > --- >

[jira] [Created] (KAFKA-18382) Change KafkaConfigTest to use kraft config

PoAn Yang created KAFKA-18382: - Summary: Change KafkaConfigTest to use kraft config Key: KAFKA-18382 URL: https://issues.apache.org/jira/browse/KAFKA-18382 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18381) Remove raftSupport in KafkaApisTest

PoAn Yang created KAFKA-18381: - Summary: Remove raftSupport in KafkaApisTest Key: KAFKA-18381 URL: https://issues.apache.org/jira/browse/KAFKA-18381 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18382) Change KafkaConfigTest to use kraft config

[ https://issues.apache.org/jira/browse/KAFKA-18382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18382. --- Resolution: Duplicate > Change KafkaConfigTest to use kraft config > ---

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #164

See

[jira] [Created] (KAFKA-18383) Remove reserved.broker.max.id, broker.id.generation.enable, and broker.id

PoAn Yang created KAFKA-18383: - Summary: Remove reserved.broker.max.id, broker.id.generation.enable, and broker.id Key: KAFKA-18383 URL: https://issues.apache.org/jira/browse/KAFKA-18383 Project: Kafka

[jira] [Created] (KAFKA-18375) Update the LICENSE-binary

Chia-Ping Tsai created KAFKA-18375: -- Summary: Update the LICENSE-binary Key: KAFKA-18375 URL: https://issues.apache.org/jira/browse/KAFKA-18375 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-18373) Remove ZkMetadataCache

PoAn Yang created KAFKA-18373: - Summary: Remove ZkMetadataCache Key: KAFKA-18373 URL: https://issues.apache.org/jira/browse/KAFKA-18373 Project: Kafka Issue Type: Sub-task Reporter: P

[jira] [Resolved] (KAFKA-18361) Remove PasswordEncoderConfigs

[ https://issues.apache.org/jira/browse/KAFKA-18361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18361. Fix Version/s: 4.0.0 Resolution: Fixed trunk: https://github.com/apache/kafka/comm

Re: Kafka Streams: Inconsistent Results with KStream-KTable Join Under Load

Seems this question was cross-posted on SO: https://stackoverflow.com/questions/79299571/inconsistent-results-with-kstream-ktable-join-under-load Left an answer there. On 12/28/24 11:45 PM, Hagiu Alexandru wrote: Hello, I'm developing a Quarkus microservice that utilizes Kafka Streams to proc

[jira] [Created] (KAFKA-18376) High CPU load when AsyncKafkaConsumer uses a small max poll value

Philip Nee created KAFKA-18376: -- Summary: High CPU load when AsyncKafkaConsumer uses a small max poll value Key: KAFKA-18376 URL: https://issues.apache.org/jira/browse/KAFKA-18376 Project: Kafka

[jira] [Created] (KAFKA-18372) Remove zookeeper config in config_property.py

黃竣陽 created KAFKA-18372: --- Summary: Remove zookeeper config in config_property.py Key: KAFKA-18372 URL: https://issues.apache.org/jira/browse/KAFKA-18372 Project: Kafka Issue Type: Improvement

Re: Request for Permission to Contribute Code Changes to Apache Kafka

Hi Kiruthiga, your email are directed to the Junk box so I didn’t notice it in time, sorry for it. there are three users with the same name, can you update your avatar so I can distinguish you from others? thank you. > On Dec 7, 2024, at 17:35, Kiruthiga Prabhakaran > wrote: > > >> Hi

[jira] [Created] (KAFKA-18371) TopicBasedRemoteLogMetadataManagerConfig exposes sensitive configuration data in logs

Vadym Zhytkevych created KAFKA-18371: Summary: TopicBasedRemoteLogMetadataManagerConfig exposes sensitive configuration data in logs Key: KAFKA-18371 URL: https://issues.apache.org/jira/browse/KAFKA-18371

[jira] [Resolved] (KAFKA-18280) fix e2e TestSecurityRollingUpgrade.test_rolling_upgrade_sasl_mechanism_phase_one

[ https://issues.apache.org/jira/browse/KAFKA-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18280. Resolution: Fixed trunk: https://github.com/apache/kafka/commit/6737178c12fbd90e9d8fc7cb7

[jira] [Created] (KAFKA-18377) pollResigned can short circuit to unattached on receiving all endquorum acks

Alyssa Huang created KAFKA-18377: Summary: pollResigned can short circuit to unattached on receiving all endquorum acks Key: KAFKA-18377 URL: https://issues.apache.org/jira/browse/KAFKA-18377 Project:

[jira] [Created] (KAFKA-18379) Enforce resigned cannot transition to any other state in same epoch

Alyssa Huang created KAFKA-18379: Summary: Enforce resigned cannot transition to any other state in same epoch Key: KAFKA-18379 URL: https://issues.apache.org/jira/browse/KAFKA-18379 Project: Kafka

[jira] [Created] (KAFKA-18374) Remove EncryptingPasswordEncoder

Chia-Ping Tsai created KAFKA-18374: -- Summary: Remove EncryptingPasswordEncoder Key: KAFKA-18374 URL: https://issues.apache.org/jira/browse/KAFKA-18374 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18378) standardize raft quorum state transitions

Alyssa Huang created KAFKA-18378: Summary: standardize raft quorum state transitions Key: KAFKA-18378 URL: https://issues.apache.org/jira/browse/KAFKA-18378 Project: Kafka Issue Type: Improve

[jira] [Created] (KAFKA-18380) Remove KafkaApisTest `raftSupport` and change test to Kraft mode

黃竣陽 created KAFKA-18380: --- Summary: Remove KafkaApisTest `raftSupport` and change test to Kraft mode Key: KAFKA-18380 URL: https://issues.apache.org/jira/browse/KAFKA-18380 Project: Kafka Issue Type: I