kafka-native image and -javaagent

I am attempt to set javaagents for the kafka-native image (like I have done with the confluent kafka images) However, the following: KAFKA_OPTS: -javaagent:/opt/jmx_prometheus/jmx_prometheus_javaagent.jar=7071:/opt/jmx_prometheus/kafka-config.yml -javaagent:/opt/jmx_prometheus/jolokia-jvm.jar=por

UncleanLeaderElectionsPerSec metric and Raft

Development, with Raft controllers, is the unclean leader election / sec metric supose to be available? kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec Nothing in documentation indicates that it isn’t as well as in code navigation nothing indicates to me that it wouldn’t

Justine Olshan / thank you (wiki access)

Justine, Thanks for taking care of the wiki access; weird in that response to the email never forward to me, I had to see it in the email archive ( https://lists.apache.org/list.html?dev@kafka.apache.org). I get other emails in dev. (I subscribed https://kafka.apache.org/contact) I am looking to

requesting permissions to contribute to Apache Kafka

Wiki ID: neil.buesing JIRA ID: nbuesing when I click on the signup link through in the KIP page I get the following message -- (Public signup for this instance is disabled. Go to our Self serve sign up page to request an account.) >You can't sign up right now -- I am not sure if I have to go thro

[jira] [Created] (KAFKA-15338) The metric group documentation for metrics added in KAFKA-13945 is incorrect

Neil Buesing created KAFKA-15338: Summary: The metric group documentation for metrics added in KAFKA-13945 is incorrect Key: KAFKA-15338 URL: https://issues.apache.org/jira/browse/KAFKA-15338 Project

oauthbearer client -- override ssl.property (unable to do so)

The code "AccessTokenRetrieverFactory" uses the "jaasConfig"'s for the properties used for building the socket factory. Shouldn't "jou.createSSLSockerFactor()" use the kafka configs for sasl/ssl overrides? I am looking to do "oauthbearer.ssl.protocol=TLSv1.2" -- but no luck - I have tried many va

KafkaPrincipal, oauth, & JWT

I am exploring how to get roles defined via oauth authentication to be passed with the KafkaPrincipal (generated by the DefaultKafkaPrincipalBuilder) so it can be used by authorization. I know the PrincipalBuilder can be replaced with a custom implementation along with an alternative KafkaPrincipa

Kafka Stream Metrics (3.3 / KAFKA-13945) and Documentation

I have been looking at the new metrics in KAFKA-13945 (KIP-846). The documentation states that this metrics are procesor-node metrics https://kafka.apache.org/documentation/#kafka_streams_node_monitoring *kafka.streams:type=stream-processor-node-metrics,thread-id=([-.\w]+),task-id=([-.\w]+),proc

broken link on download page for "previous to 0.7.0-incubating here."

The link http://sna-projects.com/kafka/downloads.php does not exist, bottom of https://kafka.apache.org/downloads and takes me to the sna-projects.com homepage to buy steroids online. "You can download releases previous to 0.7.0-incubating here ." I lo

request to be added to contribution list

Thanks, Neil Buesing

[jira] [Created] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

Neil Buesing created KAFKA-12878: Summary: Support --bootstrap-server kafka-streams-application-reset Key: KAFKA-12878 URL: https://issues.apache.org/jira/browse/KAFKA-12878 Project: Kafka