-
Notifications
You must be signed in to change notification settings - Fork 124
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Update Kafka JMX Script #216
Update Kafka JMX Script #216
Conversation
@@ -28,6 +30,29 @@ | |||
import org.testcontainers.utility.MountableFile; | |||
|
|||
abstract class KafkaIntegrationTest extends AbstractIntegrationTest { | |||
Startable createTopics = |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Any reason for moving this? Previously the containers were listed in order of execution which was a bit nicer
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nope. I had moved it initially when I was trying to leverage it for another container but ended up removing that and didn't move it back. Will resolve.
@@ -112,8 +112,8 @@ void beforeEach() { | |||
otlpServer.reset(); | |||
} | |||
|
|||
@SafeVarargs | |||
protected final void waitAndAssertMetrics(Consumer<Metric>... assertions) { | |||
@SuppressWarnings("varargs") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Don't think I see a varargs usage in this method
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Correct, fixed.
Merged in the changes, looks like everything is passing, can I get a re-review @rmfitzpatrick ? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the improvements!
Description: Update Kafka JMX metrics to update names, units, fix counters, and get more metrics.
Testing: Updated Integration test