[jira] [Created] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

Bruno Cadonna created KAFKA-9013: Summary: Flaky Test MirrorConnectorsIntegrationTest#testReplication Key: KAFKA-9013 URL: https://issues.apache.org/jira/browse/KAFKA-9013 Project: Kafka Issu

[jira] [Resolved] (KAFKA-9005) Kafka stream: “TopicAuthorizationException: Not authorized to access topics” for an internal state store

[ https://issues.apache.org/jira/browse/KAFKA-9005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9005. -- Resolution: Not A Bug > Kafka stream: “TopicAuthorizationException: Not authorized to access to

Re: [VOTE] KIP-352: Distinguish URPs caused by reassignment

Hi All, During the code review it came up that we shouldn't count replication bytes together with reassignment bytes so they count to a different metrics. This is a change in the semantics of ReplicationBytesInPerSec and ReplicationBytesOutPerSec metrics but since we plan to separate reassignment

[jira] [Created] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

Richard Wise created KAFKA-9014: --- Summary: AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list Key: KAFKA-9014 URL: https://issues.apache.org/jira/browse/KAFKA-9014

[jira] [Created] (KAFKA-9015) Unify metric names

Viktor Somogyi-Vass created KAFKA-9015: -- Summary: Unify metric names Key: KAFKA-9015 URL: https://issues.apache.org/jira/browse/KAFKA-9015 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9016) Warn when log dir stopped serving replicas

Viktor Somogyi-Vass created KAFKA-9016: -- Summary: Warn when log dir stopped serving replicas Key: KAFKA-9016 URL: https://issues.apache.org/jira/browse/KAFKA-9016 Project: Kafka Issue Ty

Re: [DISCUSS] KIP-527: Add NothingSerde to Serdes

Hello. This KIP was accepted. I created PR [1] for it. Please, review. [1] https://github.com/apache/kafka/pull/7485 В Пн, 07/10/2019 в 14:56 -0700, Matthias J. Sax пишет: > Thanks, > > Overall LGTM. Can you maybe add the corresponding package name for the > new classes? > > > > -Matthias

[jira] [Created] (KAFKA-9017) We see timeout in kafka in production cluster

Suhas created KAFKA-9017: Summary: We see timeout in kafka in production cluster Key: KAFKA-9017 URL: https://issues.apache.org/jira/browse/KAFKA-9017 Project: Kafka Issue Type: Bug Compone

[jira] [Created] (KAFKA-9018) Kafka Connect - throw clearer exceptions on serialisation errors

Robin Moffatt created KAFKA-9018: Summary: Kafka Connect - throw clearer exceptions on serialisation errors Key: KAFKA-9018 URL: https://issues.apache.org/jira/browse/KAFKA-9018 Project: Kafka

[jira] [Created] (KAFKA-9019) Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

Bill Bejeck created KAFKA-9019: -- Summary: Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig Key: KAFKA-9019 URL: https://issues.apache.org/jira/browse/KAFKA-9019

Re: [VOTE] KIP-352: Distinguish URPs caused by reassignment

+1. Thanks, Viktor. Colin On Thu, Oct 10, 2019, at 03:30, Viktor Somogyi-Vass wrote: > Hi All, > > During the code review it came up that we shouldn't count replication bytes > together with reassignment bytes so they count to a different metrics. This > is a change in the semantics of Replicat

[jira] [Resolved] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8260. Resolution: Duplicate Closing this as duplicate. > Flaky test > ConsumerBounceTest#testRo

[jira] [Created] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

Guozhang Wang created KAFKA-9020: Summary: Streams sub-topologies should be sorted by sink -> source relationship Key: KAFKA-9020 URL: https://issues.apache.org/jira/browse/KAFKA-9020 Project: Kafka

Re: [DISCUSS] KIP-515: Reorganize checkpoint system in log cleaner to be per partition

Hi, Jason, I agree that your approach is better since it's more general, more accurate and simpler. The only thing is that it may not work for the old message format. I am not sure how important it is since most users are probably already on the new message format. Perhaps we can just document thi

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

See Changes: [github] MINOR: fix compatibility-breaking bug in RequestHeader (#7479) [matthias] Add wait condition for state RUNNING (#7476) [wangguoz] KAFKA-8729, pt 3: Add broker-side logic to handle the case

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

See Changes: [cmccabe] MINOR: ListPartitionReassignmentsResponse should not be entirely failed [wangguoz] KAFKA-8743: Flaky Test Repartition{WithMerge}OptimizingIntegrationTest --

[jira] [Created] (KAFKA-9021) Broker shutdown during SSL handshake may be handled as handshake failure (Regression)

Graham Campbell created KAFKA-9021: -- Summary: Broker shutdown during SSL handshake may be handled as handshake failure (Regression) Key: KAFKA-9021 URL: https://issues.apache.org/jira/browse/KAFKA-9021

Build failed in Jenkins: kafka-trunk-jdk11 #872

See Changes: [github] MINOR: fix compatibility-breaking bug in RequestHeader (#7479) [matthias] Add wait condition for state RUNNING (#7476) [wangguoz] KAFKA-8729, pt 3: Add broker-side logic to handle the case

Build failed in Jenkins: kafka-2.4-jdk8 #8

See Changes: [cmccabe] MINOR: fix compatibility-breaking bug in RequestHeader (#7479) [wangguoz] KAFKA-8729, pt 3: Add broker-side logic to handle the case when there -- [...

[jira] [Created] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

Sophie Blee-Goldman created KAFKA-9022: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9022 URL: https://issues.apache.org/jira/

Build failed in Jenkins: kafka-trunk-jdk11 #873

See Changes: [cmccabe] MINOR: ListPartitionReassignmentsResponse should not be entirely failed [wangguoz] KAFKA-8743: Flaky Test Repartition{WithMerge}OptimizingIntegrationTest --

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

See Changes: [wangguoz] HOTFIX: fix checkstyle in Streams system test (#7494) -- [...truncated 2.43 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFail

Build failed in Jenkins: kafka-2.4-jdk8 #9

See Changes: [cmccabe] MINOR: ListPartitionReassignmentsResponse should not be entirely failed [wangguoz] KAFKA-8743: Flaky Test Repartition{WithMerge}OptimizingIntegrationTest ---

Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

You meant JSSE not JCE right? We are not talking about cryptographic providers we are talking about ssl providers hence JSSE. I do understand how JSSE Providers work and also the impact of multiple JSSE providers with same algorithms in same JVM along with sequencing challenges for the same. Like

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

See Changes: [github] MINOR: Improve assert in testCreateTopicsResponseMetadataAndConfig -- [...truncated 2.43 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

Check this out- https://github.com/apache/httpcomponents-core/blob/master/httpcore5/src/main/java/org/apache/hc/core5/ssl/SSLContextBuilder.java#L349 This is exactly what I mean by using existing provider's SSLContext implementation and customizing it with our data points. The similar thing Kafka'