Details
-
Type:
Bug
-
Status:
Closed
-
Priority:
Major
-
Resolution: Duplicate
-
Affects Version/s: 2.8.0
-
Fix Version/s: None
-
Component/s: library
-
Security Level: Public
-
Labels:None
Description
TapClient client = new TapClient(baseURIs, "default", "default", "");
Operation op = client.tapDump("test tap client");
while (client.hasMoreMessages()) {
ResponseMessage message = client.getNextMessage();
if (message != null) {
System.out.println(message.getKey());
}
}
I made the client point to a cluster that has 60 M records . The client printed out about 8M and stopped without error, when I tried again it stopped at 10M.
Operation op = client.tapDump("test tap client");
while (client.hasMoreMessages()) {
ResponseMessage message = client.getNextMessage();
if (message != null) {
System.out.println(message.getKey());
}
}
I made the client point to a cluster that has 60 M records . The client printed out about 8M and stopped without error, when I tried again it stopped at 10M.
Activity
- All
- Comments
- Work Log
- History
- Activity
- Gerrit Reviews
Raghavan Srinivas
made changes -
| Field | Original Value | New Value |
|---|---|---|
| Summary | TAP client within spy doesn't not appear cluster-aware | TAP client within spy does not appear cluster-aware |
Raghavan Srinivas
made changes -
| Description |
TapClient client = new TapClient(baseURIs, "default", "default", "");
Operation op = client.tapDump("test tap client"); while (client.hasMoreMessages()) { ResponseMessage message = client.getNextMessage(); if (message != null) { System.out.println(message.getKey()); } } I made the client point to a cluster that has 60 M records . The client printed out about 8M and stopped without error, when I tried again it stopped at 10M. I haven't tried since then , should I send the server logs? |
TapClient client = new TapClient(baseURIs, "default", "default", "");
Operation op = client.tapDump("test tap client"); while (client.hasMoreMessages()) { ResponseMessage message = client.getNextMessage(); if (message != null) { System.out.println(message.getKey()); } } I made the client point to a cluster that has 60 M records . The client printed out about 8M and stopped without error, when I tried again it stopped at 10M. |
Raghavan Srinivas
made changes -
| Status | Open [ 1 ] | Resolved [ 5 ] |
| Resolution | Duplicate [ 3 ] |
Raghavan Srinivas
made changes -
| Status | Resolved [ 5 ] | Closed [ 6 ] |