[jira] [Resolved] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

2022-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-2561. Resolution: Won't Do > Optionally support OpenSSL for SSL/TLS > --

[jira] [Resolved] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2022-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7304. Fix Version/s: 2.0.1 Assignee: Rajini Sivaram Resolution: Fixed Marking as fixed si

[jira] [Resolved] (KAFKA-4231) ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1

2022-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4231. Resolution: Cannot Reproduce > ZK metadata went inconsistent when migrating 0.10.0.0 -> 0.10.0.1 >

[jira] [Resolved] (KAFKA-6706) NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrormaker producer after 1.0 broker upgrade

2022-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6706. Fix Version/s: 1.1.1 Resolution: Fixed > NETWORK_EXCEPTION and REQUEST_TIMED_OUT in mirrorma

Re: [DISCUSS] Should we automatically close stale PRs?

2022-02-13 Thread Luke Chen
Hi Guozhang, Had a quick search on the github action, didn't find any notification related actions. However, there's a github action to auto leave a comment before closing PR.[1] So, I think at least, we can leave a comment that notify the PR participants. If the auto comment action can support me

Re: [DISCUSS] Should we automatically close stale PRs?

2022-02-13 Thread Guozhang Wang
Thanks for the investigation, Luke! I think just pining committer's ids in a comment is sufficient. On Sun, Feb 13, 2022 at 5:00 AM Luke Chen wrote: > Hi Guozhang, > > Had a quick search on the github action, didn't find any notification > related actions. > However, there's a github action to

Re: [DISCUSS] KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols

2022-02-13 Thread Guozhang Wang
Hello Riven, Thanks for bringing this proposal. As we discussed on the JIRA I'm personally in favor of this fix. But if all the proposed changes are in `ConsumerCoordinator`, then we do not need a KIP since that class is internal only. Guozhang On Sat, Feb 12, 2022 at 1:35 AM Riven Sun wrote:

Re: [VOTE] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-13 Thread Guozhang Wang
Hi Sagar, Looks good to define it in the NamedCacheMetrics. Though since this is an internal implementation detail and neither of the classes are public, we do not actually need to define it in the KIP :) Guozhang On Sat, Feb 12, 2022 at 4:22 AM Sagar wrote: > @Guozhang, > > I have sent an up

[GitHub] [kafka-site] showuon merged pull request #396: MINOR: Add CVE-2022-23302 and CVE-2022-23305 to cve-list

2022-02-13 Thread GitBox
showuon merged pull request #396: URL: https://github.com/apache/kafka-site/pull/396 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr.

Re: [DISCUSS] KIP-812: Introduce another form of the `KafkaStreams.close()` API that forces the member to leave the consumer group

2022-02-13 Thread Guozhang Wang
Thanks Seung-chan! Re: "As I read the code, we can set a consumer to leave the group while shutting down the thread, using `StreamThread#requestLeaveGroupDuringShutdown` method. Is it enough to call that method on every thread created in `KafkaStream` sometime before we call `StreamThread#shutdown

Re: [VOTE] KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-13 Thread Sagar
Thanks Guozhang. Thanks! Sagar. On Mon, Feb 14, 2022 at 7:40 AM Guozhang Wang wrote: > Hi Sagar, > > Looks good to define it in the NamedCacheMetrics. Though since this is an > internal implementation detail and neither of the classes are public, we do > not actually need to define it in the KI

Re: [DISCUSS] Should we automatically close stale PRs?

2022-02-13 Thread Ismael Juma
Hi David, I think it's a good idea to use the bot for auto closing stale PRs. The ideal flow would be: 1. Write a comment and add stale label 2. If user responds saying that the PR is still valid, the stale label is removed 3. Otherwise, the PR is closed Thanks, Ismael On Sat, Feb 5, 2022, 2:22