[jira] [Created] (KAFKA-7810) AdminClient not found flink consumer group

dengjie created KAFKA-7810: -- Summary: AdminClient not found flink consumer group Key: KAFKA-7810 URL: https://issues.apache.org/jira/browse/KAFKA-7810 Project: Kafka Issue Type: Bug Compon

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

One thing I would like to bring up is the improvements regarding cross-colo failover. I think it is an important scenario and it would be great if MM2 address the needs. I chatted with Ryanne offline via email about my thoughts. Ideally in a multi-location Kafka deployment, users would like to see

Jenkins build is back to normal : kafka-trunk-jdk8 #3301

See

[jira] [Resolved] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5994. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5021 [https://github.com/a

[jira] [Created] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commit offsets

lambdaliu created KAFKA-7811: Summary: Avoid unnecessary lock acquire when KafkaConsumer commit offsets Key: KAFKA-7811 URL: https://issues.apache.org/jira/browse/KAFKA-7811 Project: Kafka Issue

Re: [DISCUSS] KIP-379: Multiple Consumer Group Management

Hi Jason, Sorry for the late reply too. All proposed/dismissed changes done. Please review the latest PR updates: https://github.com/apache/kafka/pull/5726/ #1. Done. Backwards compatibility with old csv format is preserved. #2. Not. Considered not to omit the GROUP column for `--describe` output

[DISCUSS] KIP-379: Multiple Consumer Group Management

Hi Jason, Sorry for the late reply too. All proposed/dismissed changes done. Please review the latest PR updates: https://github.com/apache/kafka/pull/5726/ #1. Done. Backwards compatibility with old csv format is preserved. #2. Not. Considered not to omit the GROUP column for `--describe` outpu

Re: [DISCUSSION] KIP-412: Extend Admin API to support dynamic application log levels

Makes sense, thanks. Ryanne On Wed, Jan 9, 2019, 11:28 PM Stanislav Kozlovski Sorry about cutting the last message short. I was meaning to say that in > the future we would be able to introduce finer-grained logging > configuration (e.g enable debug logs for operations pertaining to this > topic

Build failed in Jenkins: kafka-trunk-jdk8 #3302

See Changes: [manikumar.reddy] KAFKA-5994; Log ClusterAuthorizationException for all ClusterAction -- [...truncated 2.25 MB...] org.apache.kafka.streams.test.OutputVerif

Re: [VOTE] - KIP-213 (new vote) - Simplified and revised.

It's a +1 (nonbinding) from me as well. Thanks for sticking with this, Adam! -John On Wed, Jan 9, 2019 at 6:22 PM Guozhang Wang wrote: > Hello Adam, > > I'm +1 on the current proposal, thanks! > > > Guozhang > > On Mon, Jan 7, 2019 at 6:13 AM Adam Bellemare > wrote: > > > Hi All > > > > I woul

Re: [VOTE] - KIP-213 (new vote) - Simplified and revised.

+1 from me. Great job on the KIP. -Bill On Thu, Jan 10, 2019 at 11:35 AM John Roesler wrote: > It's a +1 (nonbinding) from me as well. > > Thanks for sticking with this, Adam! > -John > > On Wed, Jan 9, 2019 at 6:22 PM Guozhang Wang wrote: > > > Hello Adam, > > > > I'm +1 on the current propo

Re: [VOTE] KIP-382 MirrorMaker 2.0

Hi, Ryanne, Thanks for the explanation. All make sense to me now. +1 on the KIP from me. Jun On Wed, Jan 9, 2019 at 7:16 PM Ryanne Dolan wrote: > Thanks Jun. > > > 103. My point was that the MirrorMakerConnector can die while the > Heartbeat connector is still alive. So, one can't solely rely

Re: [VOTE] KIP-349 Priorities for Source Topics

Hi Adam, This change is only intended for the basic consumer API. Cheers, -- Nick From: Adam Bellemare Sent: Sunday, January 6, 2019 11:45 AM To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-349 Priorities for Source Topics Hi Nick Is this change onl

Re: [VOTE] KIP-349 Priorities for Source Topics

Looks good to me then! +1 non-binding > On Jan 10, 2019, at 1:22 PM, Afshartous, Nick wrote: > > > Hi Adam, > > > This change is only intended for the basic consumer API. > > > Cheers, > > -- > >Nick > > > > From: Adam Bellemare > Sent: Sunday, J

Build failed in Jenkins: kafka-trunk-jdk8 #3303

See Changes: [wangguoz] MINOR: Remove throwing exception if not found from describe topics -- [...truncated 4.50 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: kafka-2.1-jdk8 #102

See Changes: [jason] KAFKA-7773; Add end to end system test relying on verifiable consumer -- [...truncated 914.99 KB...] kafka.security.auth.SimpleAclAuthorizerTest > testA

Re: [VOTE] KIP-349 Priorities for Source Topics

Hi all, Just as a quick reminder, this is not really a complete proposal. There are a bunch of unresolved issues with this KIP. One example is how this interacts with incremental fetch sessions. It is not mentioned anywhere in the KIP text. Previously we discussed some approaches, but there

[jira] [Resolved] (KAFKA-7741) Bad dependency via SBT

[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7741. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 2.2.0

[jira] [Reopened] (KAFKA-7741) Bad dependency via SBT

[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-7741: - > Bad dependency via SBT > -- > > Key: KAFKA-7741 >

Build failed in Jenkins: kafka-2.1-jdk8 #103

See Changes: [wangguoz] MINOR: Remove throwing exception if not found from describe topics -- [...truncated 914.97 KB...] kafka.security.auth.SimpleAclAuthorizerTest > testA

Jenkins build is back to normal : kafka-trunk-jdk8 #3304

See

Re: [VOTE] KIP-414: Expose Embedded ClientIds in Kafka Streams

Hi Guozhang, It sounds reasonable to me. I'm +1 (nonbinding). -John On Tue, Jan 8, 2019 at 8:51 PM Guozhang Wang wrote: > Hello folks, > > I'd like to start a voting process for the following KIP: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-414%3A+Expose+Embedded+ClientIds+in+K

Build failed in Jenkins: kafka-2.1-jdk8 #104

See Changes: [wangguoz] KAFKA-7741: Streams exclude javax dependency (#6121) -- [...truncated 916.23 KB...] kafka.security.auth.SimpleAclAuthorizerTest > testAclManagementAP