Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3913

Old consumer's metrics error when using IPv6

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 0.9.0.1, 0.10.0.0
    • Fix Version/s: None
    • Component/s: consumer
    • Labels:
      None

      Description

      The error is below:

      [2016-05-09 15:49:20,096] WARN Property security.protocol is not valid (kafka.utils.VerifiableProperties)
      [2016-05-09 15:49:20,882] WARN Error processing kafka.server:type=FetcherStats,name=RequestsPerSec,clientId=console-consumer-32775,brokerHost=fe80::92e2:baff:fe07:51cc,brokerPort=9093 (com.yammer.metrics.reporting.JmxReporter)
      javax.management.MalformedObjectNameException: Invalid character ':' in value part of property
      at javax.management.ObjectName.construct(ObjectName.java:618)
      at javax.management.ObjectName.<init>(ObjectName.java:1382)
      at com.yammer.metrics.reporting.JmxReporter.onMetricAdded(JmxReporter.java:395)
      at com.yammer.metrics.core.MetricsRegistry.notifyMetricAdded(MetricsRegistry.java:516)
      at com.yammer.metrics.core.MetricsRegistry.getOrAdd(MetricsRegistry.java:491)
      at com.yammer.metrics.core.MetricsRegistry.newMeter(MetricsRegistry.java:240)
      at kafka.metrics.KafkaMetricsGroup$class.newMeter(KafkaMetricsGroup.scala:79)
      at kafka.server.FetcherStats.newMeter(AbstractFetcherThread.scala:264)
      at kafka.server.FetcherStats.<init>(AbstractFetcherThread.scala:269)
      at kafka.server.AbstractFetcherThread.<init>(AbstractFetcherThread.scala:55)
      at kafka.consumer.ConsumerFetcherThread.<init>(ConsumerFetcherThread.scala:38)
      at kafka.consumer.ConsumerFetcherManager.createFetcherThread(ConsumerFetcherManager.scala:118)
      at kafka.server.AbstractFetcherManager$$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:83)
      at kafka.server.AbstractFetcherManager$$anonfun$addFetcherForPartitions$2.apply(AbstractFetcherManager.scala:78)
      at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:778)
      at scala.collection.immutable.Map$Map1.foreach(Map.scala:116)
      at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:777)
      at kafka.server.AbstractFetcherManager.addFetcherForPartitions(AbstractFetcherManager.scala:78)
      at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:95)
      at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              pengwei Pengwei

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment