confluent interceptors, global refresh

cpinon-grd · Oct 21, 2020 · 7ddc4b0 · 7ddc4b0
1 parent 33c2159
commit 7ddc4b0
Show file tree

Hide file tree

Showing 114 changed files with 309 additions and 3,616 deletions.
diff --git a/confluent/control-center.properties b/confluent/control-center.properties
@@ -0,0 +1,137 @@
+# (Copyright) Confluent, Inc.
+
+############################# Server Basics #############################
+
+# A comma separated list of Apache Kafka cluster host names (required)
+# NOTE: should not be localhost
+bootstrap.servers=kafka-1:19092,kafka-2:29092,kafka-3:39092
+
+# A comma separated list of ZooKeeper host names (for ACLs)
+zookeeper.connect=zookeeper-1:12181,zookeeper-2:22181,zookeeper-3:32181
+
+############################# Control Center Settings #############################
+
+# Unique identifier for the Control Center
+confluent.controlcenter.id=1
+
+# Directory for Control Center to store data
+# NOTE: this should be changed to point to a reliable directory
+confluent.controlcenter.data.dir=/tmp/confluent/control-center
+
+# License string for the Control Center
+# confluent.license=Xyz
+
+# A comma separated list of Connect host names
+#confluent.controlcenter.connect.cluster=http://kafka-connect-1:18082
+
+# KSQL cluster URL
+#confluent.controlcenter.ksql.ksqlDB.url=http://ksql-server:18088
+
+# Schema Registry cluster URL
+#confluent.controlcenter.schema.registry.url=http://schema-registry:18081
+
+# Kafka REST endpoint URL
+#confluent.controlcenter.streams.cprest.url=http://kafka-rest:18089
+
+# Settings to enable email alerts
+#confluent.controlcenter.mail.enabled=true
+#confluent.controlcenter.mail.host.name=smtp1
+#confluent.controlcenter.mail.port=587
+#confluent.controlcenter.mail.from=kafka-monitor@example.com
+#confluent.controlcenter.mail.password=abcdefg
+#confluent.controlcenter.mail.starttls.required=true
+
+# Replication for internal Control Center topics.
+# Only lower them for testing.
+# WARNING: replication factor of 1 risks data loss.
+confluent.controlcenter.internal.topics.replication=1
+
+# Number of partitions for Control Center internal topics
+# Increase for better throughput on monitored data (CPU bound)
+# NOTE: changing requires running `bin/control-center-reset` prior to restart
+confluent.controlcenter.internal.topics.partitions=2
+
+# Topic used to store Control Center configuration
+# WARNING: replication factor of 1 risks data loss.
+confluent.controlcenter.command.topic.replication=1
+
+# Enable automatic UI updates
+confluent.controlcenter.ui.autoupdate.enable=true
+
+# Enable usage data collection
+confluent.controlcenter.usage.data.collection.enable=true
+
+# Enable Controller Chart in Broker page
+#confluent.controlcenter.ui.controller.chart.enable=true
+
+# Enable hosted monitoring UI features in Control Center
+# confluent.controlcenter.hosted.monitoring.ui.enable=true
+
+############################# Control Center RBAC Settings #############################
+
+# Enable RBAC authorization in Control Center by providing a comma-separated list of Metadata Service (MDS) URLs
+#confluent.metadata.bootstrap.server.urls=http://localhost:8090
+
+# MDS credentials of an RBAC user for Control Center to act on behalf of
+# NOTE: This user must be a SystemAdmin on each Apache Kafka cluster
+#confluent.metadata.basic.auth.user.info=username:password
+
+# Enable SASL-based authentication for each Apache Kafka cluster (SASL_PLAINTEXT or SASL_SSL required)
+#confluent.controlcenter.streams.security.protocol=SASL_PLAINTEXT
+#confluent.controlcenter.kafka.<name>.security.protocol=SASL_PLAINTEXT
+
+# Enable authentication using a bearer token for Control Center's REST endpoints
+#confluent.controlcenter.rest.authentication.method=BEARER
+
+# Public key used to verify bearer tokens
+# NOTE: Must match the MDS public key
+#public.key.path=/path/to/publickey.pem
+
+############################# Broker (Metrics reporter) Monitoring #############################
+
+# Set how far back in time metrics reporter data should be processed
+#confluent.metrics.topic.skip.backlog.minutes=15
+
+############################# Stream (Interceptor) Monitoring #############################
+
+# Keep these settings default unless using non-Confluent interceptors
+
+# Override topic name for intercepted (should mach custom interceptor settings)
+#confluent.monitoring.interceptor.topic=_confluent-monitoring
+
+# Number of partitions for the intercepted topic
+confluent.monitoring.interceptor.topic.partitions=2
+
+# Amount of replication for intercepted topics
+# WARNING: replication factor of 1 risks data loss.
+confluent.monitoring.interceptor.topic.replication=1
+
+# Set how far back in time interceptor data should be processed
+#confluent.monitoring.interceptor.topic.skip.backlog.minutes=15
+
+############################# System Health (Broker) Monitoring #############################
+
+# Number of partitions for the metrics topic
+#confluent.metrics.topic.partitions=12
+
+# Replication factor for broker monitoring data
+# WARNING: replication factor of 1 risks data loss.
+confluent.metrics.topic.replication=1
+
+############################# Streams (state store) settings #############################
+
+# Increase for better throughput on data processing (CPU bound)
+#confluent.controlcenter.streams.num.stream.threads=8
+
+################################## Confluent Telemetry Settings  ##################################
+
+# To start using Telemetry, first generate a Confluent Cloud API key/secret. This can be done with
+# instructions at https://docs.confluent.io/current/cloud/using/api-keys.html. Note that you should
+# be using the '--resource cloud' flag.
+#
+# After generating an API key/secret, to enable Telemetry uncomment the lines below and paste
+# in your API key/secret.
+#
+#confluent.telemetry.enabled=true
+#confluent.telemetry.api.key=<CLOUD_API_KEY>
+#confluent.telemetry.api.secret=<CCLOUD_API_SECRET>
diff --git a/kafka-connect-datagen/README b/kafka-connect-datagen/README
diff --git a/kafka-connect-datagen/confluentinc-kafka-connect-datagen-0.2.0.zip b/kafka-connect-datagen/confluentinc-kafka-connect-datagen-0.2.0.zip
diff --git a/kafka-connect-datagen/confluentinc-kafka-connect-datagen/assets/confluent.png b/kafka-connect-datagen/confluentinc-kafka-connect-datagen/assets/confluent.png
diff --git a/kafka-connect-datagen/confluentinc-kafka-connect-datagen/doc/LICENSE b/kafka-connect-datagen/confluentinc-kafka-connect-datagen/doc/LICENSE