kafka-1670 (followup to fix system tests); Corrupt log files for segment.bytes values close to Int.MaxInt; patched by Sriharsha Chintalapani; reviewed by Jun Rao

This commit is contained in:
Sriharsha Chintalapani 2014-10-12 08:44:59 -07:00 committed by Jun Rao
parent 09b2b3cbe0
commit 1733c0bfb0
42 changed files with 203 additions and 203 deletions

View File

@ -54,7 +54,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -65,7 +65,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -76,7 +76,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -87,7 +87,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -98,7 +98,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -109,7 +109,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:sync, acks:-1, comp:0",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -54,7 +54,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -65,7 +65,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -76,7 +76,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -87,7 +87,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -98,7 +98,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -109,7 +109,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:-1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:-1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:sync, acks:-1, comp:0",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -54,7 +54,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -65,7 +65,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -76,7 +76,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -87,7 +87,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -98,7 +98,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -109,7 +109,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:sync, acks:-1, comp:0",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -54,7 +54,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -65,7 +65,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -76,7 +76,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -87,7 +87,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -98,7 +98,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -109,7 +109,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:-1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:-1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -7,7 +7,7 @@
"06":"At the end it verifies the log size and contents",
"07":"Use a consumer to verify no message loss in TARGET cluster.",
"08":"Producer dimensions : mode:async, acks:1, comp:1",
"09":"Log segment size : 10240"
"09":"Log segment size : 20480"
},
"testcase_args": {
"bounce_leader": "false",
@ -55,7 +55,7 @@
"entity_id": "4",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -66,7 +66,7 @@
"entity_id": "5",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_5_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -77,7 +77,7 @@
"entity_id": "6",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_6_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -88,7 +88,7 @@
"entity_id": "7",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_7_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -99,7 +99,7 @@
"entity_id": "8",
"port": "9095",
"broker.id": "5",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_8_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -110,7 +110,7 @@
"entity_id": "9",
"port": "9096",
"broker.id": "6",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_9_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -30,7 +30,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -41,7 +41,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -52,7 +52,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -63,7 +63,7 @@
"entity_id": "4",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -30,7 +30,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -41,7 +41,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -52,7 +52,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "5",
@ -63,7 +63,7 @@
"entity_id": "4",
"port": "9094",
"broker.id": "4",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_4_logs",
"default.replication.factor": "3",
"num.partitions": "5",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:sync, acks:-1, comp:0",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:sync, acks:-1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:sync, acks:1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:async, acks:-1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:async, acks:1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:sync, acks:-1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:async, acks:-1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:sync, acks:1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -5,7 +5,7 @@
"04":"At the end it verifies the log size and contents",
"05":"Use a consumer to verify no message loss.",
"06":"Producer dimensions : mode:async, acks:1, comp:1",
"07":"Log segment size : 10240"
"07":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -29,7 +29,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -40,7 +40,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -51,7 +51,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:0",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:0",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"log_filename": "kafka_server_9091.log",
"config_filename": "kafka_server_9091.properties"
@ -41,7 +41,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"log_filename": "kafka_server_9092.log",
"config_filename": "kafka_server_9092.properties"
@ -50,7 +50,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"log_filename": "kafka_server_9093.log",
"config_filename": "kafka_server_9093.properties"

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:0",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "1",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "1",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:-1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:sync, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",

View File

@ -8,7 +8,7 @@
"07":"At the end it verifies the log size and contents",
"08":"Use a consumer to verify no message loss.",
"09":"Producer dimensions : mode:async, acks:1, comp:1",
"10":"Log segment size : 10240"
"10":"Log segment size : 20480"
},
"testcase_args": {
"broker_type": "leader",
@ -32,7 +32,7 @@
"entity_id": "1",
"port": "9091",
"broker.id": "1",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_1_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -43,7 +43,7 @@
"entity_id": "2",
"port": "9092",
"broker.id": "2",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_2_logs",
"default.replication.factor": "3",
"num.partitions": "3",
@ -54,7 +54,7 @@
"entity_id": "3",
"port": "9093",
"broker.id": "3",
"log.segment.bytes": "10240",
"log.segment.bytes": "20480",
"log.dir": "/tmp/kafka_server_3_logs",
"default.replication.factor": "3",
"num.partitions": "3",