Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #156

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #155

See

[jira] [Created] (KAFKA-12838) Kafka Broker - Request threads inefficiently blocking during produce

Ryan Cabral created KAFKA-12838: --- Summary: Kafka Broker - Request threads inefficiently blocking during produce Key: KAFKA-12838 URL: https://issues.apache.org/jira/browse/KAFKA-12838 Project: Kafka

[GitHub] [kafka-site] topeax opened a new pull request #355: Add Axios (https://www.axios.com/) to the list of the "Powered By ❤️"

topeax opened a new pull request #355: URL: https://github.com/apache/kafka-site/pull/355 [Axios](https://axios.com) uses kafka to power some of our most critical data systems. This PR adds us to the page! @hachikuji can you take a look at this? Thanks! -- This is an automated mes

[jira] [Created] (KAFKA-12837) Process entire batch in broker metadata listener

Jose Armando Garcia Sancio created KAFKA-12837: -- Summary: Process entire batch in broker metadata listener Key: KAFKA-12837 URL: https://issues.apache.org/jira/browse/KAFKA-12837 Project:

[jira] [Resolved] (KAFKA-12342) Get rid of raft/meta log shim layer

[ https://issues.apache.org/jira/browse/KAFKA-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-12342. Resolution: Fixed > Get rid of raft/meta log shim layer >

[jira] [Resolved] (KAFKA-12543) Re-design the ownership model for snapshots

[ https://issues.apache.org/jira/browse/KAFKA-12543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-12543. Resolution: Fixed > Re-design the ownership model for snapshots >

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Hi Tom, Wow, I was way off base! I was thinking that the intent of the fencible producer was to employ it by default with 3.0, as opposed to only after the worker-level "exactly.once.source.enabled" property was flipped on. You are correct that with the case you were actually describing, there wou

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #154

See

Re: [VOTE] KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time

Hi Sanjana, Again I'm sorry for the delay. I've opened a draft PR which hopefully will let you make progress on KIP-709. Let me know if you have any questions. Thanks On Thu, May 20, 2021 at 10:10 PM Sanjana Kaundinya wrote: > > Hi Mickael, > > Apologies for pinging on this again, but just wond

Re: [VOTE] KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config

+1 (binding) Thanks Bruno! On Fri, May 21, 2021 at 8:06 AM Guozhang Wang wrote: > +1, thanks! > > On Fri, May 21, 2021 at 12:45 AM Bruno Cadonna wrote: > > > Hi, > > > > I'd like to start a vote on KIP-743 that proposes to remove config value > > 0.10.0-2.4 from Streams config built.in.metrics

Re: [REVIEW REQUESTED] - Pull Requests for KIP-633 and Addition of Missing Javadocs

Thanks Luke for this feedback. I truly appreciate it. There is always room for improvement and I will take this guidance into consideration in the future. Thanks Sophie for your initial feedback as well. I will review these feedback and take appropriate action On Fri, May 21, 2021 at 5:02 AM Lu

[jira] [Created] (KAFKA-12836) Possible race in handling IP address change

mlowicki created KAFKA-12836: Summary: Possible race in handling IP address change Key: KAFKA-12836 URL: https://issues.apache.org/jira/browse/KAFKA-12836 Project: Kafka Issue Type: Bug

Re: [VOTE] KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config

+1, thanks! On Fri, May 21, 2021 at 12:45 AM Bruno Cadonna wrote: > Hi, > > I'd like to start a vote on KIP-743 that proposes to remove config value > 0.10.0-2.4 from Streams config built.in.metrics.version. > > https://cwiki.apache.org/confluence/x/uIfOCg > > Best, > Bruno > -- -- Guozhang

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #153

See

[jira] [Created] (KAFKA-12835) Topic IDs can mismatch on brokers (after interbroker protocol version update)

Ivan Yurchenko created KAFKA-12835: -- Summary: Topic IDs can mismatch on brokers (after interbroker protocol version update) Key: KAFKA-12835 URL: https://issues.apache.org/jira/browse/KAFKA-12835 Pro

Re: [DISCUSS] KIP-737 Add canTrackSource to ReplicationPolicy

Perfect, thanks guys, will do! On Fri, May 21, 2021, 6:30 AM Matthew de Detrich wrote: > Thanks for this, I wasn't aware of the co-authored capabilities for > git/github. In this case @Ryanne I don't think I need to split apart my > commits, you can just add my email/name to the commit. Also mak

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #152

See

Re: [DISCUSS] KIP-731: Record Rate Limiting for Kafka Connect

Hi Ryanne, Thanks for the KIP. I can see this would be useful. 1. Can you elaborate on the life cycle of the RateLimiter interface (in the Javadoc)? In particular it's not clear to me how calls to accumulate() and throttleTime() can be interleaved (I assume arbitrarily). 2. It's a bit weird that

Re: [DISCUSS] KIP-737 Add canTrackSource to ReplicationPolicy

Thanks for this, I wasn't aware of the co-authored capabilities for git/github. In this case @Ryanne I don't think I need to split apart my commits, you can just add my email/name to the commit. Also make sure to add ivanyu (https://github.com/ivanyu) since he made the original PR/tests at https://

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #122

See Changes: [Manikumar Reddy] KAFKA-12820: Upgrade maven-artifact dependency to resolve CVE-2021-26291 -- [...truncated 6.35 MB...] org.apache.kafka.streams.T

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Hi Chris, Thanks for continuing to entertain some of these ideas. On Fri, May 14, 2021 at 5:06 PM Chris Egerton wrote: > [...] > That's true, but we do go from three static ACLs (write/describe on a fixed > transactional ID, and idempotent write on a fixed cluster) to a dynamic > collection of

Re: [DISCUSS] KIP-737 Add canTrackSource to ReplicationPolicy

When merging, all commits will be squashed. However, a committer can set "Co-authored-by" tags in the commit message to credit all authors. Just make sure it's clearly stated in the PR, so the committer is aware of it. https://docs.github.com/en/github/committing-changes-to-your-project/creating-a

[jira] [Resolved] (KAFKA-12522) Cast SMT should allow null value records to pass through

[ https://issues.apache.org/jira/browse/KAFKA-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-12522. Fix Version/s: 3.0.0 Resolution: Fixed > Cast SMT should allow null value records t

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #155

See Changes: [Manikumar Reddy] KAFKA-12820: Upgrade maven-artifact dependency to resolve CVE-2021-26291 -- [...truncated 3.46 MB...] org.apache.kafka.streams.T

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #151

See

Jenkins build is unstable: Kafka » Kafka Branch Builder » 2.8 #28

See

[jira] [Created] (KAFKA-12834) Remove Deprecated method MockProcessorContext#setTimestamp

Josep Prat created KAFKA-12834: -- Summary: Remove Deprecated method MockProcessorContext#setTimestamp Key: KAFKA-12834 URL: https://issues.apache.org/jira/browse/KAFKA-12834 Project: Kafka Issue

[jira] [Created] (KAFKA-12833) Remove Deprecated methods under TopologyTestDriver

Josep Prat created KAFKA-12833: -- Summary: Remove Deprecated methods under TopologyTestDriver Key: KAFKA-12833 URL: https://issues.apache.org/jira/browse/KAFKA-12833 Project: Kafka Issue Type: Su

[jira] [Created] (KAFKA-12832) Remove Deprecated methods under RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter

Josep Prat created KAFKA-12832: -- Summary: Remove Deprecated methods under RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter Key: KAFKA-12832 URL: https://issues.apache.org/jira/browse/KAFKA-12832

Re: [REVIEW REQUESTED] - Pull Requests for KIP-633 and Addition of Missing Javadocs

Hi Israel, Thanks for submitting the PR. I've reviewed those 2 PRs and left some comments there. I also see Sophie reviewed 1 of them. See if there are other guys available to review. But I'd like to suggest you look at the Contributing Code Changes

[jira] [Created] (KAFKA-12831) Remove Deprecated method StateStore#init

Josep Prat created KAFKA-12831: -- Summary: Remove Deprecated method StateStore#init Key: KAFKA-12831 URL: https://issues.apache.org/jira/browse/KAFKA-12831 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-737 Add canTrackSource to ReplicationPolicy

Sure thing, i will split out my PR into 2 commits by EOD today so that you can cherry pick the test commit in your PR. Thanks a lot for the work! On Fri, May 21, 2021 at 12:53 AM Ryanne Dolan wrote: > Matthew, I stole your integration tests to prove that point, but I would > like to make sure y

[jira] [Created] (KAFKA-12830) Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde

Josep Prat created KAFKA-12830: -- Summary: Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde Key: KAFKA-12830 URL: https://issues.apache.org/jira/browse/KAFKA-12830 Project:

[jira] [Created] (KAFKA-12829) Remove Deprecated methods under Topology

Josep Prat created KAFKA-12829: -- Summary: Remove Deprecated methods under Topology Key: KAFKA-12829 URL: https://issues.apache.org/jira/browse/KAFKA-12829 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-12828) Remove Deprecated methods under KeyQueryMetadata

Josep Prat created KAFKA-12828: -- Summary: Remove Deprecated methods under KeyQueryMetadata Key: KAFKA-12828 URL: https://issues.apache.org/jira/browse/KAFKA-12828 Project: Kafka Issue Type: Sub-

[jira] [Created] (KAFKA-12827) Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler

Josep Prat created KAFKA-12827: -- Summary: Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler Key: KAFKA-12827 URL: https://issues.apache.org/jira/browse/KAFKA-12827 Project: Kafka

[jira] [Created] (KAFKA-12826) Remove Deprecated Class Serdes (Streams)

Josep Prat created KAFKA-12826: -- Summary: Remove Deprecated Class Serdes (Streams) Key: KAFKA-12826 URL: https://issues.apache.org/jira/browse/KAFKA-12826 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-12825) Remove Deprecated method StreamsBuilder#addGlobalStore

Josep Prat created KAFKA-12825: -- Summary: Remove Deprecated method StreamsBuilder#addGlobalStore Key: KAFKA-12825 URL: https://issues.apache.org/jira/browse/KAFKA-12825 Project: Kafka Issue Type

[jira] [Created] (KAFKA-12824) Remove Deprecated method KStream#branch

Josep Prat created KAFKA-12824: -- Summary: Remove Deprecated method KStream#branch Key: KAFKA-12824 URL: https://issues.apache.org/jira/browse/KAFKA-12824 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-12823) Remove Deprecated method KStream

Josep Prat created KAFKA-12823: -- Summary: Remove Deprecated method KStream Key: KAFKA-12823 URL: https://issues.apache.org/jira/browse/KAFKA-12823 Project: Kafka Issue Type: Sub-task C

[jira] [Created] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

Josep Prat created KAFKA-12822: -- Summary: Remove Deprecated APIs of Kafka Streams in 4.0 Key: KAFKA-12822 URL: https://issues.apache.org/jira/browse/KAFKA-12822 Project: Kafka Issue Type: Bug

[VOTE] KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config

Hi, I'd like to start a vote on KIP-743 that proposes to remove config value 0.10.0-2.4 from Streams config built.in.metrics.version. https://cwiki.apache.org/confluence/x/uIfOCg Best, Bruno

Re: [DISCUSS] KIP-743: Deprecate config value 0.10.0-2.4 of Streams built-in metrics version config

Hi, Thank you for the discussion. I am fine with removing the config value completely in 3.0.0. I was a bit conservative by treating the config value as any other config value. The points you all raise make sense and I will remove the config value right away. I will not remove the config, tho

[jira] [Resolved] (KAFKA-12820) Upgrade maven-artifact dependency to resolve CVE-2021-26291

[ https://issues.apache.org/jira/browse/KAFKA-12820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-12820. --- Fix Version/s: 2.8.1 2.7.2 2.6.3 3.0.0