for (int partition = 0; partition < 10; partition++)
{
- for (int key = 0; key < 10; key++)
+ for (int key = 0; key < 10000; key++)
{
i++;
Bytes value = new Bytes(longSerializer.serialize(TOPIC, (long)i));
- if (i == 77)
+ if (i == 99977)
{
if (logicErrors)
{