You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
@@ -25,20 +26,57 @@ This guide walks you through installing an Elastic Kubernetes Service (EKS) clus
25
26
aws configure
26
27
```
27
28
28
-
1. Create an EKS cluster. To use a specific version of Kubernetes, use `--version` (1.13.x or newer version required).
29
+
1. Create a new file called `cluster-config.yaml` and add the content below to it, replacing `[your_cluster_name]`, `[your_cluster_region]`, and `[your_k8s_version]` with the appropriate values:
30
+
31
+
```yaml
32
+
apiVersion: eksctl.io/v1alpha5
33
+
kind: ClusterConfig
34
+
35
+
metadata:
36
+
name: [your_cluster_name]
37
+
region: [your_cluster_region]
38
+
version: [your_k8s_version]
39
+
tags:
40
+
karpenter.sh/discovery: [your_cluster_name]
41
+
42
+
iam:
43
+
withOIDC: true
44
+
45
+
managedNodeGroups:
46
+
- name: mng-od-4vcpu-8gb
47
+
desiredCapacity: 2
48
+
minSize: 1
49
+
maxSize: 5
50
+
instanceType: c5.xlarge
51
+
privateNetworking: true
52
+
53
+
addons:
54
+
- name: vpc-cni
55
+
attachPolicyARNs:
56
+
- arn:aws:iam::aws:policy/AmazonEKS_CNI_Policy
57
+
- name: coredns
58
+
version: latest
59
+
- name: kube-proxy
60
+
version: latest
61
+
- name: aws-ebs-csi-driver
62
+
wellKnownPolicies:
63
+
ebsCSIController: true
64
+
```
65
+
66
+
1. Create the cluster by running the following command:
Change the values for `vpc-private-subnets` to meet your requirements. You can also add additional IDs. You must specify at least two subnet IDs. If you'd rather specify public subnets, you can change `--vpc-private-subnets` to `--vpc-public-subnets`.
35
-
36
-
1. Verify kubectl context:
71
+
72
+
1. Verify the kubectl context:
37
73
38
74
```bash
39
75
kubectl config current-context
40
76
```
41
77
78
+
## Add Dapr requirements for sidecar access and default storage class:
79
+
42
80
1. Update the security group rule to allow the EKS cluster to communicate with the Dapr Sidecar by creating an inbound rule for port 4000.
43
81
44
82
```bash
@@ -49,11 +87,37 @@ This guide walks you through installing an Elastic Kubernetes Service (EKS) clus
49
87
--source-group [your_security_group]
50
88
```
51
89
90
+
2. Add a default storage class if you don't have one:
ℹ️ Note: To install Dapr using Helm, see here: https://docs.dapr.io/getting-started/install-dapr-kubernetes/#install-with-helm-advanced
109
+
110
+
ℹ️ Container images will be pulled from Docker Hub
111
+
✅ Deploying the Dapr control plane with latest version to your cluster...
112
+
✅ Deploying the Dapr dashboard with latest version to your cluster...
113
+
✅ Success! Dapr has been installed to namespace dapr-system. To verify, run `dapr status -k' in your terminal. To get started, go here: https://docs.dapr.io/getting-started
114
+
```
115
+
52
116
## Troubleshooting
53
117
54
118
### Access permissions
55
119
56
-
If you face any access permissions, make sure you are using the same AWS profile that was used to create the cluster. If needed, update the kubectl configuration with the correct profile:
120
+
If you face any access permissions, make sure you are using the same AWS profile that was used to create the cluster. If needed, update the kubectl configuration with the correct profile. More information [here](https://repost.aws/knowledge-center/eks-api-server-unauthorized-error):
Copy file name to clipboardexpand all lines: daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md
+8
Original file line number
Diff line number
Diff line change
@@ -53,6 +53,12 @@ spec:
53
53
value: 2.0.0
54
54
- name: disableTls # Optional. Disable TLS. This is not safe for production!! You should read the `Mutual TLS` section for how to use TLS.
55
55
value: "true"
56
+
- name: consumerFetchMin # Optional. Advanced setting. The minimum number of message bytes to fetch in a request - the broker will wait until at least this many are available.
57
+
value: 1
58
+
- name: consumerFetchDefault # Optional. Advanced setting. The default number of message bytes to fetch from the broker in each request.
59
+
value: 2097152
60
+
- name: channelBufferSize # Optional. Advanced setting. The number of events to buffer in internal and external channels.
61
+
value: 512
56
62
- name: schemaRegistryURL # Optional. When using Schema Registry Avro serialization/deserialization. The Schema Registry URL.
57
63
value: http://localhost:8081
58
64
- name: schemaRegistryAPIKey # Optional. When using Schema Registry Avro serialization/deserialization. The Schema Registry API Key.
@@ -111,7 +117,9 @@ spec:
111
117
| schemaLatestVersionCacheTTL | N | When using Schema Registry Avro serialization/deserialization. The TTL for schema caching when publishing a message with latest schema available. Default is 5 min |`5m`|
112
118
| clientConnectionTopicMetadataRefreshInterval | N | The interval for the client connection's topic metadata to be refreshed with the broker as a Go duration. Defaults to `9m`. |`"4m"`|
113
119
| clientConnectionKeepAliveInterval | N | The maximum time for the client connection to be kept alive with the broker, as a Go duration, before closing the connection. A zero value (default) means keeping alive indefinitely. |`"4m"`|
120
+
| consumerFetchMin | N | The minimum number of message bytes to fetch in a request - the broker will wait until at least this many are available. The default is `1`, as `0` causes the consumer to spin when no messages are available. Equivalent to the JVM's `fetch.min.bytes`. |`"2"`|
114
121
| consumerFetchDefault | N | The default number of message bytes to fetch from the broker in each request. Default is `"1048576"` bytes. |`"2097152"`|
122
+
| channelBufferSize | N | The number of events to buffer in internal and external channels. This permits the producer and consumer to continue processing some messages in the background while user code is working, greatly improving throughput. Defaults to `256`. |`"512"`|
115
123
| heartbeatInterval | N | The interval between heartbeats to the consumer coordinator. At most, the value should be set to a 1/3 of the `sessionTimeout` value. Defaults to "3s". |`"5s"`|
116
124
| sessionTimeout | N | The timeout used to detect client failures when using Kafka’s group management facility. If the broker fails to receive any heartbeats from the consumer before the expiration of this session timeout, then the consumer is removed and initiates a rebalance. Defaults to "10s". |`"20s"`|
117
125
| escapeHeaders | N | Enables URL escaping of the message header values received by the consumer. Allows receiving content with special characters that are usually not allowed in HTTP headers. Default is `false`. |`true`|
0 commit comments