[jira] [Created] (KAFKA-9660) KAFKA-1 build a kafka-exporter by java

francis lee created KAFKA-9660: -- Summary: KAFKA-1 build a kafka-exporter by java Key: KAFKA-9660 URL: https://issues.apache.org/jira/browse/KAFKA-9660 Project: Kafka Issue Type: Improvement

KIP-575: build a Kafka-Exporter by Java

hi all, KIP-575 kafka is an excellent MQ running on JVM, but no exporters JVMly. for a better future of Kafka-Ecosystems the Apache needs a formal exporter like https://github.com/apache/kafka-exporter. i wrote one for working, and hope to give to Apache. there are a lot of metric in JMX, it

[Kafka Config] Setting multiple timestamp.column.name

Hi guys, Sorry if this mail has bothered you. Currently, I want to set up a topic but it listen two column timestamp to consum data when the data is changed. Example: timestamp.column.name = createddate or modifieddate Thank for your help, glad to hear from you soon. Thanks, Hung Pham

[jira] [Created] (KAFKA-9659) Kafka Streams / Consumer fails on "fatal exception: group.instance.id gets fenced"

Rohan Desai created KAFKA-9659: -- Summary: Kafka Streams / Consumer fails on "fatal exception: group.instance.id gets fenced" Key: KAFKA-9659 URL: https://issues.apache.org/jira/browse/KAFKA-9659

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

See Changes: [github] MINOR: Add an extra check in StreamThreadTest (#8214) -- [...truncated 5.87 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-9658) Removing default user quota doesn't take effect until broker restart

Anna Povzner created KAFKA-9658: --- Summary: Removing default user quota doesn't take effect until broker restart Key: KAFKA-9658 URL: https://issues.apache.org/jira/browse/KAFKA-9658 Project: Kafka

[jira] [Created] (KAFKA-9657) Add configurable throw on unsupported protocol

Boyang Chen created KAFKA-9657: -- Summary: Add configurable throw on unsupported protocol Key: KAFKA-9657 URL: https://issues.apache.org/jira/browse/KAFKA-9657 Project: Kafka Issue Type:

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

Hi Rajini I made changes suggested by you on https://github.com/maulin-vasavada/kafka/pull/4. Please check. In particular I had challenge in 'SslFactory#configure()' method the first time to know which configs I have to add without having actual SslEngineFactory impl. I think it is best to just

[jira] [Created] (KAFKA-9656) TxnOffsetCommit should not return COORDINATOR_LOADING error for old request versions

Jason Gustafson created KAFKA-9656: -- Summary: TxnOffsetCommit should not return COORDINATOR_LOADING error for old request versions Key: KAFKA-9656 URL: https://issues.apache.org/jira/browse/KAFKA-9656

[jira] [Resolved] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

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

[jira] [Created] (KAFKA-9655) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe

Matthias J. Sax created KAFKA-9655: -- Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe Key: KAFKA-9655 URL: https://issues.apache.org/jira/browse/KAFKA-9655

Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams

Regarding the metric name, I was actually trying to be consistent with the node-level `suppression-emit` as I feel this one's characteristics is closer to that. I other folks feels better to align with the task-level "dropped-records" I think I can be convinced too. Guozhang On Wed, Mar 4, 2020

kafka dev subscription

kafka dev com

subscribe kafka dev list

subscription to dev

[jira] [Created] (KAFKA-9654) ReplicaAlterLogDirsThread can't be created again if the previous ReplicaAlterLogDirsThreadmeet encounters leader epoch error

Chia-Ping Tsai created KAFKA-9654: - Summary: ReplicaAlterLogDirsThread can't be created again if the previous ReplicaAlterLogDirsThreadmeet encounters leader epoch error Key: KAFKA-9654 URL:

[jira] [Created] (KAFKA-9653) Duplicate tasks on workers after rebalance

Agam Brahma created KAFKA-9653: -- Summary: Duplicate tasks on workers after rebalance Key: KAFKA-9653 URL: https://issues.apache.org/jira/browse/KAFKA-9653 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9652) Throttle time metric needs to be updated for KIP-219

Jason Gustafson created KAFKA-9652: -- Summary: Throttle time metric needs to be updated for KIP-219 Key: KAFKA-9652 URL: https://issues.apache.org/jira/browse/KAFKA-9652 Project: Kafka Issue

[jira] [Created] (KAFKA-9651) Divide by zero in DefaultPartitioner

Tom Bentley created KAFKA-9651: -- Summary: Divide by zero in DefaultPartitioner Key: KAFKA-9651 URL: https://issues.apache.org/jira/browse/KAFKA-9651 Project: Kafka Issue Type: Bug

US Department of Veterans Affairs Apache Kafka Product Inquiry

Greetings, I am reaching out to you from the Department of Veterans Affairs (VA) where I am part of the team that reviews various information-based products from an information security perspective for use within VA. I am reviewing information regarding Apache Kafka and have a few questions

[jira] [Created] (KAFKA-9650) Include human readable quantities for default config docs

Tom Bentley created KAFKA-9650: -- Summary: Include human readable quantities for default config docs Key: KAFKA-9650 URL: https://issues.apache.org/jira/browse/KAFKA-9650 Project: Kafka Issue

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

See

[jira] [Created] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

Sören Henning created KAFKA-9649: Summary: Remove/Warn on use of TimeWindowedSerde with no specified window size Key: KAFKA-9649 URL: https://issues.apache.org/jira/browse/KAFKA-9649 Project: Kafka

[jira] [Created] (KAFKA-9648) kafka server should resize backlog when create serversocket

li xiangyuan created KAFKA-9648: --- Summary: kafka server should resize backlog when create serversocket Key: KAFKA-9648 URL: https://issues.apache.org/jira/browse/KAFKA-9648 Project: Kafka

[jira] [Created] (KAFKA-9647) Add ability to suppress until window end (not close)

Sören Henning created KAFKA-9647: Summary: Add ability to suppress until window end (not close) Key: KAFKA-9647 URL: https://issues.apache.org/jira/browse/KAFKA-9647 Project: Kafka Issue

[jira] [Created] (KAFKA-9646) kafka consumer cause high cpu usage

li xiangyuan created KAFKA-9646: --- Summary: kafka consumer cause high cpu usage Key: KAFKA-9646 URL: https://issues.apache.org/jira/browse/KAFKA-9646 Project: Kafka Issue Type: Improvement

Re: Subject: [VOTE] 2.4.1 RC0

Hi Bill, I built from source and ran unit and integration tests. They passed. There was a large number of skipped tests, but I'm assuming that is intentional. Cheers Eno On Tue, Mar 3, 2020 at 8:42 PM Eric Lalonde wrote: > > Hi, > > I ran: > $

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

See

[jira] [Resolved] (KAFKA-9632) Transient test failure: PartitionLockTest.testAppendReplicaFetchWithUpdateIsr

[ https://issues.apache.org/jira/browse/KAFKA-9632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9632. --- Fix Version/s: 2.6.0 Reviewer: Manikumar Resolution: Fixed > Transient test

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

See Changes: [github] KAFKA-9618: Directory deletion failure leading to error task RocksDB -- [...truncated 2.90 MB...]

Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams

Hi all, may I make a non-binding proposal for the metric name? I would prefer "skipped-idempotent-updates" to be consistent with the "dropped-records". Best, Bruno On Tue, Mar 3, 2020 at 11:57 PM Richard Yu wrote: > > Hi all, > > Thanks for the discussion! > > @Guozhang, I will make the

Re: [VOTE] KIP-570: Add leader epoch in StopReplicaRequest

Hi Jun, You're right. I have noticed it while implementing it. I plan to use a default value as a sentinel in the protocol (e.g. -2) to cover this case. David On Wed, Mar 4, 2020 at 3:18 AM Jun Rao wrote: > Hi, David, > > Thanks for the KIP. +1 from me too. Just one comment below. > > 1.