Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #440

See Changes: [github] MINOR: log 2min processing summary of StreamThread loop (#9941) -- [...truncated 7.13 MB...] MockProcessorContextStateStoreTest > build

Unsubscribe from Notifications

Hi, Kindly unsubscribe our email from your daily notification. We don't want to receive any further notification. I would be highly appreciated if you can check and remove our email from your list. Thanks Team HirinGuru

[GitHub] [kafka-site] mimaison commented on pull request #322: KAFKA-6223: Use archive.apache.org for older releases

mimaison commented on pull request #322: URL: https://github.com/apache/kafka-site/pull/322#issuecomment-764846591 @mjsax can you take a look? Thanks This is an automated message from the Apache Git Service. To respond to the

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #392

See Changes: [github] MINOR: log 2min processing summary of StreamThread loop (#9941) -- [...truncated 3.55 MB...] MockProcessorContextStateStoreTest > build

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #421

See Changes: [github] MINOR: log 2min processing summary of StreamThread loop (#9941) -- [...truncated 3.58 MB...] OutputVerifierTest > shouldFailIfValueIsD

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #439

See Changes: [github] MINOR: Drop enable.metadata.quorum config (#9934) -- [...truncated 3.58 MB...] TopologyTestDriverAtLeastOnceTest > shouldNotCreateSta

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #391

See Changes: [github] MINOR: Drop enable.metadata.quorum config (#9934) -- [...truncated 3.55 MB...] TestTopicsTest > testEmptyTopic() STARTED TestTopicsTest

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #420

See Changes: [github] MINOR: Tweak IBM i support in "stop" scripts (#9810) [github] MINOR: Import RaftConfig config definitions into KafkaConfig (#9916) [github] MINOR: Drop enable.metadata.quorum

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #390

See Changes: [github] MINOR: Tweak IBM i support in "stop" scripts (#9810) [github] MINOR: Import RaftConfig config definitions into KafkaConfig (#9916) -- [

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #419

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #438

See Changes: [github] MINOR: Tweak IBM i support in "stop" scripts (#9810) [github] MINOR: Import RaftConfig config definitions into KafkaConfig (#9916) --

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Mickael, Thanks for taking another look into the KIP, regards your questions - I believe we need both "isMM2InternalTopic" and `ReplicationPolicy.isInternalTopic` as `ReplicationPolicy.isInternalTopic` does check if a topic is Kafka internal topic, while `isMM2InternalTopic` is just focusing i

Re: [DISCUSS] KIP-676: Respect the logging hierarchy

Tom, et al., I'm really late to the party and mistakenly thought the scope of this KIP included only the broker. But I now see in the KIP-676 [1] text the following claim: Kafka exposes a number of APIs for describing and changing logger levels: > > * The Kafka broker exposes the DescribeConfigs

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #389

See Changes: [github] MINOR: Refactor DescribeAuthorizedOperationsTest (#9938) [github] KAFKA-12185: fix ConcurrentModificationException in newly added Tasks container class (#9940) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #437

See Changes: [github] MINOR: Refactor DescribeAuthorizedOperationsTest (#9938) [github] KAFKA-12185: fix ConcurrentModificationException in newly added Tasks container class (#9940) -

[jira] [Created] (KAFKA-12232) Distinguish API scope by broker/controller

Jason Gustafson created KAFKA-12232: --- Summary: Distinguish API scope by broker/controller Key: KAFKA-12232 URL: https://issues.apache.org/jira/browse/KAFKA-12232 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-12231) Consumer Lag increases linearly until a Consumer-Group Rebalance is initiated

Scott Kidder created KAFKA-12231: Summary: Consumer Lag increases linearly until a Consumer-Group Rebalance is initiated Key: KAFKA-12231 URL: https://issues.apache.org/jira/browse/KAFKA-12231 Project

[GitHub] [kafka-site] mimaison commented on pull request #322: KAFKA-6223: Use archive.apache.org for older releases

mimaison commented on pull request #322: URL: https://github.com/apache/kafka-site/pull/322#issuecomment-764846591 @mjsax can you take a look? Thanks This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

[ https://issues.apache.org/jira/browse/KAFKA-12230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Ponomarev resolved KAFKA-12230. Resolution: Duplicate Duplicate of KAFKA-12190 > Some Kafka TopologyTestDriver-based unit

[jira] [Created] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

Ivan Ponomarev created KAFKA-12230: -- Summary: Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system Key: KAFKA-12230 URL: https://issues.apache.org/jira/browse/KAFKA-12230

Re: [Connect] Different validation requirements for connector creation and update

Hi Gunnar, It's not possible to do this in a generalized fashion with the API provided by the framework today. Trying to hack your way around things by setting a flag or storing the connector name in some shared JVM state wouldn't work in a cluster with more than one worker since that state would

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Omnia, Thanks for the updates. Sorry for the delay but I have a few more small questions about the API: - Do we really need "isMM2InternalTopic()"? There's already "ReplicationPolicy.isInternalTopic()". If so, we need to explain the difference between these 2 methods. - Is "isCheckpointTopic()

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #418

See Changes: [github] KAFKA-12152; Idempotent Producer does not reset the sequence number of partitions without in-flight batches (#9832) -- [...truncated 7

Re: Kafka Advisory Topic

Hi, I am on the ActiveMQ PMC and I think this is a very good idea to have a way to do advisories/notifications/events (whatever you want to call it). In ActiveMQ classic you have advisories and in Artemis you have notifications. Having management messages that can be subscribed to in real time is

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #436

See

Re: [DISCUSS] Apache Kafka 2.8.0 release

Hi John, KIP-659 was just accepted as well, can it be added to the release plan? https://cwiki.apache.org/confluence/display/KAFKA/KIP-659%3A+Improve+TimeWindowedDeserializer+and+TimeWindowedSerde+to+handle+window+size Thanks, Leah On Thu, Jan 14, 2021 at 9:36 AM John Roesler wrote: > Hi David

Re: [VOTE] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

Thanks everyone, with that I'll go ahead and close this KIP with 4 binding votes (Sophie, Guozhang, John, Matthias). Thanks for the lively discussion! Leah On Wed, Jan 20, 2021 at 6:00 PM Matthias J. Sax wrote: > Thanks for reviving this KIP, Leah. > > I agree that we should not extend the scop

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #388

See Changes: [github] KAFKA-12152; Idempotent Producer does not reset the sequence number of partitions without in-flight batches (#9832) -- [...truncated 3.

[Connect] Different validation requirements for connector creation and update

Hi, In the Debezium community, we ran into an interesting corner case of connector config validation [1]. The Debezium Postgres connector requires a database resource called a "replication slot", which identifies this connector to the database and tracks progress it has made reading the TX log. T

Re: [VOTE] KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Can I get a vote on this, please? Best Omnia On Tue, Dec 15, 2020 at 12:16 PM Omnia Ibrahim wrote: > If anyone interested in reading the discussions you can find it here > https://www.mail-archive.com/dev@kafka.apache.org/msg113373.html > > On Tue, Dec 8, 2020 at 4:01 PM Omnia Ibrahim > wro

[jira] [Resolved] (KAFKA-12152) Idempotent Producer does not reset the sequence number of partitions without in-flight batches

[ https://issues.apache.org/jira/browse/KAFKA-12152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12152. - Fix Version/s: 2.7.1 2.8.0 Reviewer: Jason Gustafson Resolutio