首先附上kafka Api文档
打开文档就看到了kafka所有的包如下
org.apache.kafka.clients.consumer
org.apache.kafka.clients.producer
org.apache.kafka.common
org.apache.kafka.common.config
org.apache.kafka.common.errors
org.apache.kafka.common.serialization
org.apache.kafka.connect.connector
org.apache.kafka.connect.data
org.apache.kafka.connect.errors
org.apache.kafka.connect.sink
org.apache.kafka.connect.source
org.apache.kafka.connect.storage
org.apache.kafka.connect.transforms
org.apache.kafka.connect.util
org.apache.kafka.streams
org.apache.kafka.streams.errors
org.apache.kafka.streams.kstream
org.apache.kafka.streams.processor
org.apache.kafka.streams.state