##
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
##
# This file contains some of the configurations for the Kafka Connect distributed worker. This file is intended
# to be used with the examples, and some settings may differ from those used in a production system, especially
# the `bootstrap.servers` and those specifying replication factors.
# A list of host/port pairs to use for establishing the initial connection to the Kafka cluster.
bootstrap.servers=localhost:9092
# unique name for the cluster, used in forming the Connect cluster group. Note that this must not conflict with consumer group IDs
group.id=connect-cluster
# The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
# need to configure these based on the format they want their data in when loaded from or stored into Kafka
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
# Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply
# it to
key.converter.schemas.enable=true
value.converter.schemas.enable=true
# Topic to use for storing offsets. This topic should have many partitions and be replicated and compacted.
# Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create
# the topic before starting Kafka Connect if a specific topic configuration is needed.
# Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value.
# Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able
# to run this example on a single-broker cluster and so here we instead set the replication factor to 1.
offset.storage.topic=connect-offsets
offset.storage.replication.factor=1
#offset.storage.partitions=25
# Topic to use for storing connector and task configurations; note that this should be a single partition, highly replicated,
# and compacted topic. Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create
# the topic before starting Kafka Connect if a specific topic configuration is needed.
# Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value.
# Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able
# to run this example on a single-broker cluster and so here we instead set the replication factor to 1.
config.storage.topic=connect-configs
config.storage.replication.factor=1
# Topic to use for storing statuses. This topic can have multiple partitions and should be replicated and compacted.
# Kafka Connect will attempt to create the topic automatically when needed, but you can always manually create
# the topic before starting Kafka Connect if a specific topic configuration is needed.
# Most users will want to use the built-in default replication factor of 3 or in some cases even specify a larger value.
# Since this means there must be at least as many brokers as the maximum replication factor used, we'd like to be able
# to run this example on a single-broker cluster and so here we instead set the replication factor to 1.
status.storage.topic=connect-status
status.storage.replication.factor=1
#status.storage.partitions=5
# Flush much faster than normal, which is useful for testing/debugging
offset.flush.interval.ms=10000
# List of comma-separated URIs the REST API will listen on. The supported protocols are HTTP and HTTPS.
# Specify hostname as 0.0.0.0 to bind to all interfaces.
# Leave hostname empty to bind to default interface.
# Examples of legal listener lists: HTTP://myhost:8083,HTTPS://myhost:8084"
#listeners=HTTP://:8083
# The Hostname & Port that will be given out to other workers to connect to i.e. URLs that are routable from other servers.
# If not set, it uses the value for "listeners" if configured.
#rest.advertised.host.name=
#rest.advertised.port=
#rest.advertised.listener=
# Set to a list of filesystem paths separated by commas (,) to enable class loading isolation for plugins
# (connectors, converters, transformations). The list should consist of top level directories that include
# any combination of:
# a) directories immediately containing jars with plugins and their dependencies
# b) uber-jars with plugins and their dependencies
# c) directories immediately containing the package directory structure of classes of plugins and their dependencies
# Examples:
# plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors,
#plugin.path=
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
详细说明:https://blog.csdn.net/a342874650/article/details/137800259 本文介绍了一款集成图形化界面配置和一键自启功能的Kafka与Zookeeper服务管理软件。该软件通过直观易用的图形界面,使用户能够轻松完成Kafka和Zookeeper的配置工作,有效避免了手动编辑配置文件可能带来的错误和不便。同时,软件还提供了详细的错误日志记录功能,帮助用户快速定位并解决潜在问题,极大提升了服务部署和管理的便捷性和效率。对于Kafka和Zookeeper的新手用户而言,这款软件无疑是一款非常友好且实用的工具。 软件运行环境:Win10 x64 编译工具:Visual Studio 2022 运行依赖:java jdk 1.8、.net framework 4.6.2 Kafka版本:kafka_2.13-3.6.0 程序目录说明: java jdk 1.8安装程序:jdk-8u271-windows-x64.exe .net framework 4.6.2安装程序:ndp462-devpack-kb3151934-enu.exe
资源推荐
资源详情
资源评论
收起资源包目录
Kafka服务端(含Zookeeper)一键自启软件 (209个子文件)
eclipse-public-license-2.0 14KB
eclipse-distribution-license-1.0 2KB
snapshot.0 457B
log.1 64MB
CDDL+GPL-1.1 38KB
argparse-MIT 1KB
kafka-run-class.bat 5KB
zookeeper-server-start.bat 1KB
connect-distributed.bat 1KB
connect-standalone.bat 1KB
zookeeper-shell.bat 1KB
kafka-server-stop.bat 997B
kafka-streams-application-reset.bat 983B
connect-plugin-path.bat 966B
kafka-consumer-perf-test.bat 949B
kafka-producer-perf-test.bat 940B
kafka-console-producer.bat 925B
kafka-console-consumer.bat 925B
zookeeper-server-stop.bat 905B
kafka-replica-verification.bat 897B
kafka-delegation-tokens.bat 896B
kafka-metadata-quorum.bat 895B
kafka-delete-records.bat 894B
kafka-transactions.bat 893B
kafka-e2e-latency.bat 889B
kafka-features.bat 888B
kafka-reassign-partitions.bat 888B
kafka-log-dirs.bat 888B
kafka-broker-api-versions.bat 885B
kafka-cluster.bat 885B
kafka-leader-election.bat 884B
kafka-consumer-groups.bat 883B
kafka-jmx.bat 881B
kafka-dump-log.bat 878B
kafka-get-offsets.bat 877B
kafka-configs.bat 876B
kafka-topics.bat 875B
kafka-mirror-maker.bat 874B
kafka-storage.bat 874B
kafka-acls.bat 873B
kafka-server-start-1.bat 698B
kafka-server-start-1.bat 698B
kafka-server-start-2.bat 697B
kafka-server-start-3.bat 697B
kafka-server-start-2.bat 697B
kafka-server-start-3.bat 697B
kafka-server-start-2.bat 553B
kafka-server-start-3.bat 553B
kafka-server-start-1.bat 553B
checker-qual-MIT 22KB
cleaner-offset-checkpoint 0B
trogdor.conf 1KB
kafka_server_jaas.conf 239B
KafkaStartServer.exe.Config 409B
DWTFYWTPL 484B
jdk-8u271-windows-x64.exe 166.79MB
ndp462-devpack-kb3151934-enu.exe 82.85MB
KafkaStartServer.exe 30KB
rocksdbjni-7.9.2.jar 55.31MB
zstd-jni-1.5.5-1.jar 5.71MB
scala-library-2.13.11.jar 5.69MB
kafka-clients-3.6.0.jar 5.01MB
kafka_2.13-3.6.0.jar 4.87MB
scala-reflect-2.13.11.jar 3.59MB
snappy-java-1.1.10.4.jar 2.01MB
kafka-streams-3.6.0.jar 1.77MB
jackson-databind-2.13.5.jar 1.47MB
zookeeper-3.8.2.jar 1.27MB
jersey-common-2.39.1.jar 1.17MB
jline-3.22.0.jar 1.01MB
jersey-server-2.39.1.jar 928KB
caffeine-2.9.3.jar 891KB
javassist-3.29.2-GA.jar 776KB
jetty-server-9.4.52.v20230823.jar 719KB
kafka-metadata-3.6.0.jar 719KB
connect-runtime-3.6.0.jar 709KB
lz4-java-1.8.0.jar 667KB
netty-common-4.1.94.Final.jar 644KB
scala-java8-compat_2.13-1.0.2.jar 625KB
commons-collections-3.2.2.jar 575KB
jetty-util-9.4.52.v20230823.jar 570KB
netty-handler-4.1.94.Final.jar 542KB
commons-lang3-3.8.1.jar 490KB
netty-transport-4.1.94.Final.jar 477KB
jackson-module-scala_2.13-2.13.5.jar 449KB
jackson-core-2.13.5.jar 366KB
netty-codec-4.1.94.Final.jar 337KB
trogdor-3.6.0.jar 334KB
reload4j-1.2.25.jar 326KB
jetty-client-9.4.52.v20230823.jar 320KB
kafka-storage-3.6.0.jar 320KB
commons-io-2.11.0.jar 319KB
jersey-client-2.39.1.jar 301KB
netty-buffer-4.1.94.Final.jar 299KB
jose4j-0.9.3.jar 291KB
kafka-group-coordinator-3.6.0.jar 285KB
kafka-tools-3.6.0.jar 277KB
plexus-utils-3.3.1.jar 256KB
zookeeper-jute-3.8.2.jar 250KB
commons-beanutils-1.9.4.jar 241KB
共 209 条
- 1
- 2
- 3
资源评论
孤蓬&听雨
- 粉丝: 7051
- 资源: 326
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功