Re: OAuth Library - Open Source Contribution to Kafka

Christopher X Bogan has sent you an email via Gmail confidential mode: [image: Gmail logo]Re: OAuth Library - Open Source Contribution to Kafka

OAuth Library - Open Source Contribution to Kafka

Hello Apache Kafka Dev Team, My team at the company I work for recently implemented an OAuth Library for access control on Kafka Broker, producers, consumers, streams applications and topics. We are looking to Open Source this software with Apache Kafka. What would be the process for going forward

[jira] [Resolved] (KAFKA-9291) error starting consumer

[ https://issues.apache.org/jira/browse/KAFKA-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming resolved KAFKA-9291. --- Resolution: Abandoned I made a mistake when debugging > error starting consumer > --

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

See

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

See Changes: [github] KAFKA-9138: Add system test for relational joins (#7664) -- [...truncated 5.58 MB...] org.apache.kafka.streams.test.TestRecordTest > testProducerRe

[DISCUSS] KIP-546: Add quota-specific APIs to the Admin Client, redux

Hello all, I'm reviving the discussion for adding a quotas API to the admin client by submitting a new proposal. There are some notable changes from previous attempts, namely a way to deduce the effective quota for a client (entity), a way to query for configured quotas, and the concept of "units"

[jira] [Created] (KAFKA-9293) NPE in DumpLogSegments with --offsets-decoder

Jason Gustafson created KAFKA-9293: -- Summary: NPE in DumpLogSegments with --offsets-decoder Key: KAFKA-9293 URL: https://issues.apache.org/jira/browse/KAFKA-9293 Project: Kafka Issue Type: B

[jira] [Resolved] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

[ https://issues.apache.org/jira/browse/KAFKA-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9138. - Resolution: Fixed Added the system test in https://github.com/apache/kafka/commit/717ce42a6d68d3

[jira] [Created] (KAFKA-9292) KIP-551: Expose disk read and write metrics

Colin McCabe created KAFKA-9292: --- Summary: KIP-551: Expose disk read and write metrics Key: KAFKA-9292 URL: https://issues.apache.org/jira/browse/KAFKA-9292 Project: Kafka Issue Type: Improveme

Re: [DISCUSS] KIP-489 Kafka Consumer Record Latency Metric

Hello again, There has been some interest in this KIP recently. I'm bumping the thread to encourage feedback on the design. Regards, Sean On Mon, Jul 15, 2019 at 9:01 AM Sean Glover wrote: > To hopefully spark some discussion I've copied the motivation section from > the KIP: > > Consumer lag

Re: Minimum replication for Exactly Once semantics

Hi Rajesh, The reason why three brokers are recommended for EOS is because of the default replication factor of some of the internal topics used to implement it. If you tweak those configurations, you could run with fewer (although that's not necessarily a good idea). best, Colin On Wed, De

[jira] [Created] (KAFKA-9291) remove the code of KAFKA-9288 which bring fatal bug

dengziming created KAFKA-9291: - Summary: remove the code of KAFKA-9288 which bring fatal bug Key: KAFKA-9291 URL: https://issues.apache.org/jira/browse/KAFKA-9291 Project: Kafka Issue Type: Impro

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

See Changes: [github] HOTFIX: Add comment to remind ordering restrictions on [github] KAFKA-9288: Do not allow the same object to be inserted multiple times -- [...trunc

Minimum replication for Exactly Once semantics

Hi all, Kafka Streams application with Exactly once processing semantics, the default replication factor of broker is 3 i.e transaction.state.log.replication.factor In doc its mentioned that atleast 3 brokers are required for exactly once. What is the minimum replication factor required for exac

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

See Changes: [github] MINOR: Simplify the timeout logic to handle protocol in Connect [github] HOTFIX: Add comment to remind ordering restrictions on [github] KAFKA-9288: Do not allow the same object to be in

[jira] [Created] (KAFKA-9290) Update IQ related JavaDocs

Matthias J. Sax created KAFKA-9290: -- Summary: Update IQ related JavaDocs Key: KAFKA-9290 URL: https://issues.apache.org/jira/browse/KAFKA-9290 Project: Kafka Issue Type: Improvement