[DISCUSS] KIP-554: Add Broker-side SCRAM Config API

Hi all, I posted a KIP about adding a new SCRAM configuration API on the broker. Check it out here if you get a chance: https://cwiki.apache.org/confluence/x/ihERCQ cheers, Colin

[DISCUSS] KIP-604: Remove ZooKeeper Flags from the Administrative Tools

Hi all, I posted a KIP about removing the deprecated --zookeeper flags from our administrative tools. Check it out here: https://cwiki.apache.org/confluence/x/kRARCQ best, Colin

[jira] [Created] (KAFKA-9945) TopicCommand should support --if-exists and --if-not-exists when --bootstrap-server is used

Colin McCabe created KAFKA-9945: --- Summary: TopicCommand should support --if-exists and --if-not-exists when --bootstrap-server is used Key: KAFKA-9945 URL: https://issues.apache.org/jira/browse/KAFKA-9945

Build failed in Jenkins: kafka-2.5-jdk8 #108

See Changes: [konstantine] KAFKA-9633: Ensure ConfigProviders are closed (#8204) -- [...truncated 4.80 MB...] kafka.cluster.PartitionTest > testFetchOffsetSnapshotEpochValid

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

See Changes: [github] KAFKA-6145: Remove check to reuse previous assignment (#8590) -- [...truncated 3.06 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shoul

Build failed in Jenkins: kafka-trunk-jdk14 #46

See Changes: [github] KAFKA-6145: Remove check to reuse previous assignment (#8590) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest > castWholeR

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

See Changes: [github] KAFKA-6145: Remove check to reuse previous assignment (#8590) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTe

Re: [DISCUSS] KIP-598: Augment TopologyDescription with store and source / sink serde information

Guozhang, thanks for the KIP! Couple of comments/questions. (1) In the new TopologyDescription output, the line for the windowed-count processor is: > Processor: myname (stores: [(myname-store, serdes: [SessionWindowedSerde, > FullChangeSerde])]) For this case, both Serdes are wrappers and u

Re: [DISCUSS] KIP-596 Safely abort Producer transactions during application shutdown

Thanks for the KIP. Make sense to me. I think you can start a vote. One minor comment about the code example: From my understanding, a producer should always be closed (independent if there was no error, a transient error, or a fatal error). If that is correct, than the code example seems to be mi

Re: Need permission to update Ecosystem wiki page

I found an account name `otis` and granted permission. (Hope it's the right account :)) -Matthias On 4/26/20 7:12 PM, Otis Gospodnetić wrote: > Hi, > > I'd like to update https://cwiki.apache.org/confluence/display/KAFKA > /Ecosystem > I see we have one sort of outdated link there, and I'd lik

Re: [DISCUSS] KIP-605 Expand Connect Worker Internal Topic Settings

Much needed, thanks. Ryanne On Thu, Apr 30, 2020 at 4:59 PM Randall Hauch wrote: > Hello! > > I'd like to use this thread to discuss KIP-605, which expands some of the > properties that the Connect distributed worker uses when creating internal > topics: > > > https://cwiki.apache.org/confluenc

[DISCUSS] KIP-605 Expand Connect Worker Internal Topic Settings

Hello! I'd like to use this thread to discuss KIP-605, which expands some of the properties that the Connect distributed worker uses when creating internal topics: https://cwiki.apache.org/confluence/display/KAFKA/KIP-605%3A+Expand+Connect+Worker+Internal+Topic+Settings Best regards, Randall

[jira] [Created] (KAFKA-9944) Allow HTTP Response Headers to be Configured for Kafka Connect

Jeff Huang created KAFKA-9944: - Summary: Allow HTTP Response Headers to be Configured for Kafka Connect Key: KAFKA-9944 URL: https://issues.apache.org/jira/browse/KAFKA-9944 Project: Kafka Issue

Re: [Discuss] KIP-582 Add a "continue" option for Kafka Connect error handling

Hi Chris and Andrew, Thanks a lot for your reply! I think in most cases it is easier to analysis broken records in an external system rather than in a Kafka DLQ topic. While it might be possible to directly analysis broken records with Kafka, people are generally more familiar with external to

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

See

Jenkins build is back to normal : kafka-2.4-jdk8 #195

See

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

See Changes: [github] KAFKA-9633: Ensure ConfigProviders are closed (#8204) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.FlattenTest > tombstoneEven

[GitHub] [kafka-site] hartantothio opened a new pull request #263: Added KS2020 (Virtual)

hartantothio opened a new pull request #263: URL: https://github.com/apache/kafka-site/pull/263 ## Reviewers @guozhangwang @mjsax This is an automated message from the Apache Git Service. To respond to the message, please

Build failed in Jenkins: kafka-trunk-jdk14 #45

See Changes: [github] KAFKA-9633: Ensure ConfigProviders are closed (#8204) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest > castFieldsWithSchem

[jira] [Created] (KAFKA-9943) Enable TLSv.1.3 in system tests "run all" execution.

Nikolay Izhikov created KAFKA-9943: -- Summary: Enable TLSv.1.3 in system tests "run all" execution. Key: KAFKA-9943 URL: https://issues.apache.org/jira/browse/KAFKA-9943 Project: Kafka Issue

Re: [DISCUSS] KIP-553: Enable TLSv1.3 by default and disable all protocols except [TLSV1.2, TLSV1.3]

Ticket created: https://issues.apache.org/jira/browse/KAFKA-9943 I will prepare the PR, shortly. > 27 апр. 2020 г., в 17:55, Ismael Juma написал(а): > > Yes, a PR would be great. > > Ismael > > On Mon, Apr 27, 2020, 2:10 AM Nikolay Izhikov wrote: > >> Hello, Ismael. >> >> AFAIK we don’t r

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

See Changes: [github] KAFKA-8835; KIP-352 docs update (#7434) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest > testWithSchemaNu

Build failed in Jenkins: kafka-trunk-jdk14 #44

See Changes: [github] KAFKA-8835; KIP-352 docs update (#7434) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest > testWithSchemaNull

Jenkins build is back to normal : kafka-2.5-jdk8 #107

See

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi David, Thanks for the KIP. If I understand the proposed throttling algorithm, an initial request would be allowed (possibly making K negative) and only subsequent requests (before K became positive) would receive the QUOTA_VIOLATED. That would mean it was still possible to block the controller

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

See Changes: [github] MINOR: Fix unused arguments used in formatted string and log messages [github] MINOR: Fix typo and rephrase content in ops docs (#8581) [manikumar] KAFKA-9034: Use double quotes around $JA

Build failed in Jenkins: kafka-2.5-jdk8 #106

See Changes: [konstantine] KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses [konstantine] KAFKA-9922: Update demo instructions in examples README (#8559) --

[jira] [Resolved] (KAFKA-7805) Use --bootstrap-server option for kafka-topics.sh in ducktape tests where applicable

[ https://issues.apache.org/jira/browse/KAFKA-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass resolved KAFKA-7805. Resolution: Fixed > Use --bootstrap-server option for kafka-topics.sh in ducktape t

[jira] [Resolved] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9936. -- Resolution: Not A Bug > kafka-streams 2.5.0 missing dependency? > -

Build failed in Jenkins: kafka-trunk-jdk14 #43

See Changes: [manikumar] KAFKA-9034: Use double quotes around $JAVA_HOME evn variable -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.FlattenTest > testUn

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

See Changes: [vvcephei] MINOR: reuse pseudo-topic in FKJoin (#8296) [vvcephei] KAFKA-9925: decorate pseudo-topics with app id (#8574) [vvcephei] MINOR: ignore streams generated directory from 2.5+ [konstantine] M

[jira] [Resolved] (KAFKA-8818) CreatePartitions Request protocol documentation

[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-8818. --- Resolution: Invalid > CreatePartitions Request protocol documentation > -

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

See Changes: [manikumar] KAFKA-9034: Use double quotes around $JAVA_HOME evn variable -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.CastTest > castWh

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

See Changes: [github] KAFKA-9922: Update demo instructions in examples README (#8559) [github] KAFKA-9652: Fix throttle metric in RequestChannel and request log due to [github] MINOR: Fix broken JMX link in do

[jira] [Resolved] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

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

Build failed in Jenkins: kafka-trunk-jdk14 #42

See Changes: [github] MINOR: Fix typo and rephrase content in ops docs (#8581) -- [...truncated 1.52 MB...] org.apache.kafka.connect.transforms.TimestampConverterTest > t