DockerFile should have JProfiler installation.
RUN wget <JProfiler file location> -P /tmp/ && \
tar -xzf /tmp/<JProfiler file> -C /usr/local && \
rm /tmp/<JProfiler file>
| package com.caffinc.grex.core; | |
| /** | |
| * SPDX-License-Identifier: MIT | |
| * | |
| * Generates Load on the CPU by keeping it busy for the given load percentage | |
| * @author Sriram | |
| */ | |
| public class Load { | |
| /** |
| import java.util | |
| import org.apache.kafka.clients.consumer.KafkaConsumer | |
| import scala.collection.JavaConverters._ | |
| object ConsumerExample extends App { | |
| import java.util.Properties |
| import java.net.URLDecoder | |
| def parseUrlParameters(url: String) = { | |
| url.split("&").map( v => { | |
| val m = v.split("=", 2).map(s => URLDecoder.decode(s, "UTF-8")) | |
| m(0) -> m(1) | |
| }).toMap | |
| } |
| /* | |
| * Copyright 2002-2012 the original author or authors. | |
| * | |
| * Licensed under the Apache License, Version 2.0 (the "License"); | |
| * you may not use this file except in compliance with the License. | |
| * You may obtain a copy of the License at | |
| * | |
| * http://www.apache.org/licenses/LICENSE-2.0 | |
| * | |
| * Unless required by applicable law or agreed to in writing, software |