[kafka] branch trunk updated (ea72ede -> 7e1c39f)

[cm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from ea72ede  MINOR: Do not override retries for idempotent producers (#8097)
     add 7e1c39f  KAFKA-9106 make metrics exposed via jmx configurable (#7674)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control-core.xml                 |  5 ++
 .../kafka/clients/admin/KafkaAdminClient.java      |  4 +-
 .../kafka/clients/consumer/KafkaConsumer.java      |  4 +-
 .../kafka/clients/producer/KafkaProducer.java      |  4 +-
 .../apache/kafka/common/metrics/JmxReporter.java   | 90 ++++++++++++++++++++--
 .../kafka/common/metrics/MetricsReporter.java      | 19 ++++-
 .../kafka/common/metrics/JmxReporterTest.java      | 44 +++++++++++
 .../connect/mirror/MirrorConnectorConfig.java      |  4 +-
 .../kafka/connect/runtime/ConnectMetrics.java      | 17 ++--
 .../runtime/distributed/WorkerGroupMember.java     |  4 +-
 .../runtime/errors/ErrorHandlingMetrics.java       |  9 ---
 .../connect/runtime/WorkerSourceTaskTest.java      |  3 +-
 .../errors/RetryWithToleranceOperatorTest.java     | 23 +++++-
 .../java/kafka/metrics/FilteringJmxReporter.java   | 62 +++++++++++++++
 .../java/kafka/metrics/KafkaYammerMetrics.java     | 76 ++++++++++++++++++
 .../kafka/metrics/KafkaCSVMetricsReporter.scala    |  5 +-
 .../scala/kafka/metrics/KafkaMetricsGroup.scala    | 11 ++-
 .../scala/kafka/server/DynamicBrokerConfig.scala   |  1 +
 core/src/main/scala/kafka/server/KafkaServer.scala | 13 +++-
 .../kafka/api/EndToEndAuthorizationTest.scala      |  4 +-
 .../scala/integration/kafka/api/MetricsTest.scala  | 10 +--
 .../kafka/api/SslAdminIntegrationTest.scala        |  4 +-
 .../server/DynamicBrokerReconfigurationTest.scala  | 10 +--
 .../scala/unit/kafka/cluster/PartitionTest.scala   |  8 +-
 .../controller/ControllerEventManagerTest.scala    | 10 +--
 .../controller/ControllerIntegrationTest.scala     |  4 +-
 .../group/GroupMetadataManagerTest.scala           |  4 +-
 .../TransactionMarkerChannelManagerTest.scala      |  4 +-
 .../MetricsDuringTopicCreationDeletionTest.scala   | 19 ++---
 .../unit/kafka/log/LogCleanerIntegrationTest.scala |  5 +-
 core/src/test/scala/unit/kafka/log/LogTest.scala   |  4 +-
 .../scala/unit/kafka/log/LogValidatorTest.scala    |  4 +-
 .../scala/unit/kafka/metrics/MetricsTest.scala     | 35 +++++++--
 .../unit/kafka/network/SocketServerTest.scala      | 11 ++-
 .../kafka/server/AbstractFetcherManagerTest.scala  |  4 +-
 .../kafka/server/AbstractFetcherThreadTest.scala   |  6 +-
 .../unit/kafka/server/ProduceRequestTest.scala     |  4 +-
 .../test/scala/unit/kafka/utils/TestUtils.scala    |  8 +-
 .../unit/kafka/zookeeper/ZooKeeperClientTest.scala |  8 +-
 .../org/apache/kafka/streams/KafkaStreams.java     |  4 +-
 40 files changed, 447 insertions(+), 121 deletions(-)
 create mode 100644 core/src/main/java/kafka/metrics/FilteringJmxReporter.java
 create mode 100644 core/src/main/java/kafka/metrics/KafkaYammerMetrics.java