Skip to content

childe/healer

BranchesTags

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

1,265 Commits
.github/workflows
.github/workflows
 
 
command
command
 
 
docker
docker
 
 
.gitignore
.gitignore
 
 
Makefile
Makefile
 
 
README.md
README.md
 
 
alter_config_request.go
alter_config_request.go
 
 
alter_config_response.go
alter_config_response.go
 
 
alter_partition_reassignments_request.go
alter_partition_reassignments_request.go
 
 
alter_partition_reassignments_response.go
alter_partition_reassignments_response.go
 
 
apiversions_request.go
apiversions_request.go
 
 
apiversions_response.go
apiversions_response.go
 
 
assign.go
assign.go
 
 
assign_test.go
assign_test.go
 
 
broker.go
broker.go
 
 
broker_test.go
broker_test.go
 
 
brokers.go
brokers.go
 
 
client.go
client.go
 
 
client_describe_logdirs_test.go
client_describe_logdirs_test.go
 
 
client_group_test.go
client_group_test.go
 
 
client_topic_test.go
client_topic_test.go
 
 
compressor.go
compressor.go
 
 
config.go
config.go
 
 
config_test.go
config_test.go
 
 
conn_mock.go
conn_mock.go
 
 
consumer.go
consumer.go
 
 
create_partitions_request.go
create_partitions_request.go
 
 
create_partitions_response.go
create_partitions_response.go
 
 
create_topics_request.go
create_topics_request.go
 
 
create_topics_response.go
create_topics_response.go
 
 
delete_groups_request.go
delete_groups_request.go
 
 
delete_groups_response.go
delete_groups_response.go
 
 
delete_topics_request.go
delete_topics_request.go
 
 
delete_topics_response.go
delete_topics_response.go
 
 
describe_configs_request.go
describe_configs_request.go
 
 
describe_configs_response.go
describe_configs_response.go
 
 
describe_groups_request.go
describe_groups_request.go
 
 
describe_groups_response.go
describe_groups_response.go
 
 
describe_logdirs_request.go
describe_logdirs_request.go
 
 
describe_logdirs_response.go
describe_logdirs_response.go
 
 
elect_leaders_request.go
elect_leaders_request.go
 
 
elect_leaders_response.go
elect_leaders_response.go
 
 
error.go
error.go
 
 
errorcode.go
errorcode.go
 
 
fetch_request.go
fetch_request.go
 
 
fetch_response.go
fetch_response.go
 
 
findcoordinator_request.go
findcoordinator_request.go
 
 
findcoordinator_response.go
findcoordinator_response.go
 
 
findcoordinator_response_test.go
findcoordinator_response_test.go
 
 
findcoordinator_test.go
findcoordinator_test.go
 
 
go.mod
go.mod
 
 
go.sum
go.sum
 
 
group.go
group.go
 
 
group_consumer.go
group_consumer.go
 
 
group_consumer_test.go
group_consumer_test.go
 
 
gzip_compressor.go
gzip_compressor.go
 
 
heartbeat_request.go
heartbeat_request.go
 
 
heartbeat_response.go
heartbeat_response.go
 
 
helper.go
helper.go
 
 
hi.goconvey
hi.goconvey
 
 
incremental_alter_config_request.go
incremental_alter_config_request.go
 
 
incremental_alter_config_request_test.go
incremental_alter_config_request_test.go
 
 
incremental_alter_config_response.go
incremental_alter_config_response.go
 
 
joingroup_request.go
joingroup_request.go
 
 
joingroup_response.go
joingroup_response.go
 
 
leave_group_request.go
leave_group_request.go
 
 
leave_group_response.go
leave_group_response.go
 
 
list_groups_request.go
list_groups_request.go
 
 
list_groups_response.go
list_groups_response.go
 
 
list_partition_reassignments_request.go
list_partition_reassignments_request.go
 
 
list_partition_reassignments_response.go
list_partition_reassignments_response.go
 
 
log.go
log.go
 
 
lz4_compressor.go
lz4_compressor.go
 
 
message.go
message.go
 
 
metadata_request.go
metadata_request.go
 
 
metadata_response.go
metadata_response.go
 
 
none_compressor.go
none_compressor.go
 
 
offset_commit_request.go
offset_commit_request.go
 
 
offset_commit_response.go
offset_commit_response.go
 
 
offset_commit_test.go
offset_commit_test.go
 
 
offset_fetch_request.go
offset_fetch_request.go
 
 
offset_fetch_response.go
offset_fetch_response.go
 
 
offset_fetch_test.go
offset_fetch_test.go
 
 
offset_request.go
offset_request.go
 
 
offset_response.go
offset_response.go
 
 
offsets_test.go
offsets_test.go
 
 
primitive_types_decode.go
primitive_types_decode.go
 
 
produce_request.go
produce_request.go
 
 
produce_response.go
produce_response.go
 
 
producer.go
producer.go
 
 
request.go
request.go
 
 
resource_types.go
resource_types.go
 
 
response.go
response.go
 
 
sasl_authenticate_request.go
sasl_authenticate_request.go
 
 
sasl_authenticate_response.go
sasl_authenticate_response.go
 
 
sasl_handshake_request.go
sasl_handshake_request.go
 
 
sasl_handshake_response.go
sasl_handshake_response.go
 
 
sasl_handshake_test.go
sasl_handshake_test.go
 
 
sasl_plain.go
sasl_plain.go
 
 
simple_consumer.go
simple_consumer.go
 
 

Repository files navigation

INSTALL

go install github.com/childe/healer/command/healer@latest

Docker

docker pull rmself/healer:latest

what can healer command do

  • produce messages
  • consume messages
  • get metadata
  • create topics
  • delete topics
  • create(increase) partitons
  • describe configs
  • alter configs
  • alter partiton assignments
  • get offsets
  • get pendings
  • reset offsets
  • (re)elect leaders
  • rest apis of doing jobs above

Code Examples

Group Consumer

group consumer(cluster style)

https://github.com/childe/healer/blob/master/command/healer/cmd/group-consumer.go

Producer

https://github.com/childe/healer/blob/master/command/healer/cmd/console-producer.go

Console Consumer

one consumer consume messages from all partitons

https://github.com/childe/healer/blob/master/command/healer/cmd/console-consumer.go

Simple Consumer

consume from only one certain partition

https://github.com/childe/healer/blob/master/command/healer/cmd/simple-consumer.go

About

golang lib for kafka

Topics

go golang kafka kafka-lib

Resources

Readme
Activity

Stars

24 stars

Watchers

8 watching

Forks

18 forks
Report repository

Releases

50 tags

Packages

No packages published

Contributors 3

  •  
  •  
  •  

Languages