KAFKA-2442: Fixing transiently failing test #160
Conversation
|
kafka-trunk-git-pr #192 SUCCESS |
| for (i <- 0 to count) { | ||
| val payload = i.toString.getBytes | ||
| numBytesProduced += payload.length | ||
| val payload = Array[Byte](100) | ||
| p.send(new ProducerRecord[Array[Byte], Array[Byte]](topic1, null, null, payload), | ||
| new ErrorLoggingCallback(topic1, null, null, true)).get() | ||
| Thread.sleep(1) |
There was a problem hiding this comment.
Can you remind me why this was needed and if it isn't we can remove it.
|
@auradkar, @jjkoshy : I had a look. One way to trigger the original test to fail consistently is to set the logging to TRACE in test.resources.log4j.properties. The new test passes, however the code is out of date with the recent trunk at this point. Could you resolve the conflicts if you get a chance? |
|
@jjkoshy @lindong28 Is this JIRA still valid? |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
@guozhangwang I was not aware of this ticket. Not sure if it is still an issue. I would prefer to just close this ticket if there is no ongoing complaint of this issue. |
|
@lindong28 cool thanks. |
…pache#160) In Phase 1 of RBAC, metadata server will be embedded in brokers. Add a metadata provider that will be loaded by our authorizer to load the metadata server plugin. The actual metadata server endpoints will be added by the implementation of this plugin. Reviewers: Milo Simpson <milo@confluent.io>, Manikumar Reddy O <manikumar.reddy@gmail.com>
Made the following changes: