Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congratulations Harsha! On Fri, Apr 19, 2019 at 5:49 AM Manikumar wrote: > > Congrats Harsha!. > > On Fri, Apr 19, 2019 at 7:43 AM Dong Lin wrote: > > > Congratulations Sriharsh! > > > > On Thu, Apr 18, 2019 at 11:46 AM Jun Rao wrote: > > > > > Hi, Everyone, > > > > > > Sriharsh Chintalapan ha

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats Matthias! On Fri, Apr 19, 2019 at 6:07 AM Vahid Hashemian wrote: > > Congratulations Matthias! > > --Vahid > > On Thu, Apr 18, 2019 at 9:39 PM Manikumar wrote: > > > Congrats Matthias!. well deserved. > > > > On Fri, Apr 19, 2019 at 7:44 AM Dong Lin wrote: > > > > > Congratulations Mat

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats Matthias!! On 4/19/19 11:28 AM, Mickael Maison wrote: Congrats Matthias! On Fri, Apr 19, 2019 at 6:07 AM Vahid Hashemian wrote: Congratulations Matthias! --Vahid On Thu, Apr 18, 2019 at 9:39 PM Manikumar wrote: Congrats Matthias!. well deserved. On Fri, Apr 19, 2019 at 7:44 AM

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congrats Harsha! On Fri, Apr 19, 2019 at 2:58 PM Mickael Maison wrote: > Congratulations Harsha! > > > On Fri, Apr 19, 2019 at 5:49 AM Manikumar > wrote: > > > > Congrats Harsha!. > > > > On Fri, Apr 19, 2019 at 7:43 AM Dong Lin wrote: > > > > > Congratulations Sriharsh! > > > > > > On Thu, Ap

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congratulations Matthias! On Fri, Apr 19, 2019 at 2:59 PM Jorge Quilcate wrote: > Congrats Matthias!! > > On 4/19/19 11:28 AM, Mickael Maison wrote: > > Congrats Matthias! > > > > On Fri, Apr 19, 2019 at 6:07 AM Vahid Hashemian > > wrote: > >> Congratulations Matthias! > >> > >> --Vahid > >> >

Re: Kafka point in time recovery?

Hello Kumar, if I got it correctly, you can try with the method offsetsForTimes from the KafkaConsumer Api. Maybe you can reset the offset to a particular timestamp and consume up to a certain offset or timestamp. https://kafka.apache.org/22/javadoc/?org/apache/kafka/clients/consumer/KafkaConsume

[jira] [Created] (KAFKA-8261) snappyjava.dll not removed after consumer restart.

Yurii created KAFKA-8261: Summary: snappyjava.dll not removed after consumer restart. Key: KAFKA-8261 URL: https://issues.apache.org/jira/browse/KAFKA-8261 Project: Kafka Issue Type: Bug Co

[jira] [Created] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

Matthias J. Sax created KAFKA-8262: -- Summary: Flaky Test MetricsIntegrationTest#testStreamMetric Key: KAFKA-8262 URL: https://issues.apache.org/jira/browse/KAFKA-8262 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

Matthias J. Sax created KAFKA-8263: -- Summary: Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore Key: KAFKA-8263 URL: https://issues.apache.org/jira/browse/KAFKA-8263 Project: Kafka

[jira] [Created] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

Matthias J. Sax created KAFKA-8264: -- Summary: Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition Key: KAFKA-8264 URL: https://issues.apache.org/jira/browse/KAFKA-8264 Project:

Re: [VOTE] KIP-433: Block old clients on brokers

Thanks Ying for updating the KIP. Hi Ismael, Given min.api.version allows admin/users to specifiy min.version for each request this should address your concerns right? Thanks, Harsha On Wed, Apr 17, 2019, at 2:29 PM, Ying Zheng wrote: > I have updated the config description in the

Re: [DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

Resending an email I sent this Monday but didn't make it to the mailing list: Hi Chris, thanks for the KIP! I have the following initial comments: 1. In its current form, the code snippet gives the impression that this is a new interface or an interface that completely replaces the existin

Re: [DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

Hi Konstantine, Thanks for your comments. I'll respond to them in the order you provided them: 1. Clarify of ConnectClusterState code block: Good point. I've altered the code block in the KIP to remove the outer 'interface ConnectClusterState {' snippet and include only the additional methods. Ha

[jira] [Created] (KAFKA-8265) Connect Client Config Override policy

Magesh kumar Nandakumar created KAFKA-8265: -- Summary: Connect Client Config Override policy Key: KAFKA-8265 URL: https://issues.apache.org/jira/browse/KAFKA-8265 Project: Kafka Issue

[DISCUSS] KIP-458: Connector Client Config Override Policy

Hi all, I've posted "KIP-458: Connector Client Config Override Policy", which allows users to override the connector client configurations based on a policy defined by the administrator. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP-458%3A+Connector+Client+Config+O

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats!! -James Sent from my iPhone > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > Hello Everyone, > > I'm glad to announce that Matthias J. Sax is now a member of Kafka PMC. > > Matthias has been a committer since Jan. 2018, and since then he continued > to be active in the commu

Re: [DISCUSS] KIP-451: Make TopologyTestDriver output iterable

Hi Matthias Seems I got a bit ahead of myself. With option C my aim was a simple alternative which gives back all output records that have happened up to this point (and which have not been removed by calls to readOutput). Based on that the user can decide how to step through or compare the records

Re: [VOTE] KIP-421: Automatically resolve external configurations.

+1. Thanks, Tejal. best, Colin On Thu, Apr 18, 2019, at 15:02, TEJAL ADSUL wrote: > Hi All, > > As we have reached a consensus on the design, I would like to start a > vote for KIP-421. Below are the links for this proposal: > > KIP Link: > https://cwiki.apache.org/confluence/pages/viewpage.

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congratulations Matthias! Well deserved! -Lei On Fri, Apr 19, 2019 at 2:55 PM James Cheng wrote: > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > > > Hello Everyone, > > > > I'm glad to announce that Matthias J. Sax is now a member of

Re: [DISCUSS] KIP-455: Create an Administrative API for Replica Reassignment

On Wed, Apr 17, 2019, at 17:23, Robert Barrett wrote: > Thanks for the KIP, Colin. I have a couple questions: > > 1. What's the reasoning for requiring cancellation of a reassignment before > submitting a new one? It seems like overriding an existing reassignment > could be done with a single upda

[jira] [Created] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

Jason Gustafson created KAFKA-8266: -- Summary: Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup` Key: KAFKA-8266 URL: https://issues.apache.org/jira/browse/KAFKA-8266 Pr

[jira] [Resolved] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-7965. - Resolution: Fixed > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroup

[jira] [Created] (KAFKA-8267) Flaky Test SaslAuthenticatorTest#testUserCredentialsUnavailableForScramMechanism

Matthias J. Sax created KAFKA-8267: -- Summary: Flaky Test SaslAuthenticatorTest#testUserCredentialsUnavailableForScramMechanism Key: KAFKA-8267 URL: https://issues.apache.org/jira/browse/KAFKA-8267 Pr

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Thank you all! -Matthias On 4/19/19 3:58 PM, Lei Chen wrote: > Congratulations Matthias! Well deserved! > > -Lei > > On Fri, Apr 19, 2019 at 2:55 PM James Cheng > wrote: > > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, a

Re: [VOTE] KIP-421: Automatically resolve external configurations.

+1 On Thu, Apr 18, 2019, 3:02 PM TEJAL ADSUL wrote: > Hi All, > > As we have reached a consensus on the design, I would like to start a vote > for KIP-421. Below are the links for this proposal: > > KIP Link: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=100829515 > Discussi

Jenkins build is back to normal : kafka-trunk-jdk11 #449

See

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

See Changes: [cshapi] KAFKA-7965; Fix flaky test ConsumerBounceTest -- [...truncated 4.75 MB...] org.apache.kafka.connect.runtime.ConnectorConfigTest > emptyConnectorName

Jenkins build is back to normal : kafka-2.2-jdk8 #87

See

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

See Changes: [github] MINOR: Java8 cleanup (#6599) [github] MINOR: Java8 cleanup (#6598) -- [...truncated 2.37 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Jenkins build is back to normal : kafka-2.1-jdk8 #167

See