[
https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1772:
-----------------------------
Description:
- utility int8
- command int8
- format int8
- args variable length bytes
utility
0 - Broker
1 - Topic
2 - Replication
3 - Controller
4 - Consumer
5 - Producer
Command
0 - Create
1 - Alter
3 - Delete
4 - List
5 - Audit
format
0 - JSON
args e.g. (which would equate to the data structure values == 2,1,0)
"meta-store": {
{"zookeeper":"localhost:12913/kafka"}
}"args": {
"partitions":
[
{"topic": "topic1", "partition": "0"},
{"topic": "topic1", "partition": "1"},
{"topic": "topic1", "partition": "2"},
{"topic": "topic2", "partition": "0"},
{"topic": "topic2", "partition": "1"},
]
}
was:
- timestamp
- utility int8
- command int8
- format int8
- args variable length bytes
utility
0 - Broker
1 - Topic
2 - Replication
3 - Controller
4 - Consumer
5 - Producer
Command
0 - Create
1 - Alter
3 - Delete
4 - List
5 - Audit
format
0 - JSON
args e.g. (which would equate to the data structure values == 2,1,0)
"meta-store": {
{"zookeeper":"localhost:12913/kafka"}
}"args": {
"partitions":
[
{"topic": "topic1", "partition": "0"},
{"topic": "topic1", "partition": "1"},
{"topic": "topic1", "partition": "2"},
{"topic": "topic2", "partition": "0"},
{"topic": "topic2", "partition": "1"},
]
}
> Add an Admin message type for request response
> ----------------------------------------------
>
> Key: KAFKA-1772
> URL: https://issues.apache.org/jira/browse/KAFKA-1772
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Joe Stein
> Assignee: Andrii Biletskyi
> Fix For: 0.8.3
>
>
> - utility int8
> - command int8
> - format int8
> - args variable length bytes
> utility
> 0 - Broker
> 1 - Topic
> 2 - Replication
> 3 - Controller
> 4 - Consumer
> 5 - Producer
> Command
> 0 - Create
> 1 - Alter
> 3 - Delete
> 4 - List
> 5 - Audit
> format
> 0 - JSON
> args e.g. (which would equate to the data structure values == 2,1,0)
> "meta-store": {
> {"zookeeper":"localhost:12913/kafka"}
> }"args": {
> "partitions":
> [
> {"topic": "topic1", "partition": "0"},
> {"topic": "topic1", "partition": "1"},
> {"topic": "topic1", "partition": "2"},
>
> {"topic": "topic2", "partition": "0"},
> {"topic": "topic2", "partition": "1"},
> ]
> }
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
