-
Notifications
You must be signed in to change notification settings - Fork 566
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
Moving 2 tests from KafkaMP to KafkaSE #1918
Conversation
Signed-off-by: Jorge Bescos Gascon <jorge.bescos.gascon@oracle.com>
@danielkec is this PR ready to be merged ? |
Map<String, Object> config = new HashMap<>(); | ||
config.put("bootstrap.servers", KAFKA_SERVER); | ||
config.put("key.serializer", LongSerializer.class.getName()); | ||
config.put("value.serializer", StringSerializer.class.getName()); |
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.
This config seems not to be used anywhere
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.
I forgot to remove it. Now that config is in AbstractKafkaTest.produceAndCheck
Map<String, Object> config = new HashMap<>(); | ||
config.put("bootstrap.servers", KAFKA_SERVER); | ||
config.put("key.serializer", LongSerializer.class.getName()); | ||
config.put("value.serializer", StringSerializer.class.getName()); |
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.
here too
I have ran it 1564 times locally and it seems super stable 👍 |
Signed-off-by: Jorge Bescos Gascon <jorge.bescos.gascon@oracle.com>
This should solve the issues of that disabled 2 tests, because there is no other consumer in the moment we get the uncommitted events from Kafka.