Files

.circleci
.github
compress
examples
fixtures
gzip
lz4
protocol
- addoffsetstotxn
- addpartitionstotxn
- alterconfigs
- alterpartitionreassignments
- apiversions
- createpartitions
- createtopics
  - createtopics.go
- deletetopics
- describeconfigs
- describegroups
- electleaders
- endtxn
- fetch
- findcoordinator
- heartbeat
- incrementalalterconfigs
- initproducerid
- listgroups
- listoffsets
- metadata
- offsetcommit
- offsetfetch
- produce
- prototest
- saslauthenticate
- saslhandshake
- txnoffsetcommit
- buffer.go
- buffer_test.go
- cluster.go
- conn.go
- decode.go
- encode.go
- error.go
- protocol.go
- protocol_test.go
- record.go
- record_batch.go
- record_batch_test.go
- record_v1.go
- record_v2.go
- reflect.go
- reflect_unsafe.go
- request.go
- response.go
- roundtrip.go
- size.go
sasl
snappy
testing
topics
zstd
.gitattributes
.gitignore
CODE_OF_CONDUCT.md
CONTRIBUTING.md
LICENSE
Makefile
README.md
addoffsetstotxn.go
addoffsetstotxn_test.go
addpartitionstotxn.go
addpartitionstotxn_test.go
address.go
address_test.go
alterconfigs.go
alterconfigs_test.go
alterpartitionreassignments.go
alterpartitionreassignments_test.go
apiversions.go
apiversions_test.go
balancer.go
balancer_test.go
batch.go
batch_test.go
buffer.go
builder_test.go
client.go
client_test.go
commit.go
commit_test.go
compression.go
conn.go
conn_test.go
consumergroup.go
consumergroup_test.go
crc32.go
crc32_test.go
createpartitions.go
createpartitions_test.go
createtopics.go
createtopics_test.go
deletetopics.go
deletetopics_test.go
describeconfigs.go
describeconfigs_test.go
describegroups.go
describegroups_test.go
dialer.go
dialer_test.go
discard.go
discard_test.go
docker-compose-241.yml
docker-compose.010.yml
docker-compose.yml
electleaders.go
electleaders_test.go
endtxn.go
error.go
error_test.go
example_consumergroup_test.go
example_groupbalancer_test.go
example_writer_test.go
fetch.go
fetch_test.go
findcoordinator.go
findcoordinator_test.go
go.mod
go.sum
groupbalancer.go
groupbalancer_test.go
heartbeat.go
heartbeat_test.go
incrementalalterconfigs.go
incrementalalterconfigs_test.go
initproducerid.go
initproducerid_test.go
joingroup.go
joingroup_test.go
kafka.go
kafka_test.go
leavegroup.go
leavegroup_test.go
listgroups.go
listgroups_test.go
listoffset.go
listoffset_test.go
logger.go
message.go
message_reader.go
message_test.go
metadata.go
metadata_test.go
offsetcommit.go
offsetcommit_test.go
offsetfetch.go
offsetfetch_test.go
produce.go
produce_test.go
protocol.go
protocol_test.go
read.go
read_test.go
reader.go
reader_test.go
record.go
recordbatch.go
resolver.go
saslauthenticate.go
saslauthenticate_test.go
saslhandshake.go
saslhandshake_test.go
sizeof.go
stats.go
syncgroup.go
syncgroup_test.go
time.go
transport.go
transport_test.go
txnoffsetcommit.go
txnoffsetcommit_test.go
write.go
write_test.go
writer.go
writer_test.go

createtopics

Name		Name	Last commit message	Last commit date
parent directory ..
createtopics.go		createtopics.go

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Files

createtopics

createtopics

Files

createtopics

Directory actions

More options

Directory actions

More options

Latest commit

History

createtopics

Folders and files

parent directory