Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Sets other useful labels, for #78 and #56 | Staffan Olsson | 2018-01-08 | 2 | -7/+9 |
| | |||||
* | Revert "Deprecates our own statefulset pod label kafka-broker-id" | Staffan Olsson | 2018-01-08 | 2 | -3/+0 |
| | | | | This reverts commit 096e3bdfba31d2918520011886a6a0d1f1b08c84. | ||||
* | Adds the required RBAC for the init script to set the kafka-broker-id label | Staffan Olsson | 2018-01-08 | 1 | -0/+41 |
| | |||||
* | Merge pull request #115 from StevenACoffman/cleanup | solsson | 2018-01-08 | 4 | -7/+5 |
|\ | | | | | Minor cleanups | ||||
| * | cleanup: Minor cleanups | Steve Coffman | 2018-01-05 | 4 | -7/+5 |
|/ | |||||
* | Merge pull request #92 from Yolean/1.8-kube-events | solsson | 2017-12-18 | 3 | -0/+170 |
|\ | | | | | Stream kube events to topic, as opt-in folder instead of addon | ||||
| * | Modernize based on1.8-kube-events | Staffan Olsson | 2017-12-18 | 3 | -38/+6 |
| | | | | | | | | | | | | | | * https://github.com/Yolean/kubernetes-kafka/pull/107 * https://github.com/Yolean/kubernetes-kafka/issues/101 * https://github.com/Yolean/fluent-bit-kubernetes-kafka/commit/e045ef1ef03f9fd299575a7aa9ca312e6687e441 * https://github.com/Yolean/kubernetes-kafka/pull/52 | ||||
| * | Uses kafkacat build as in tests and logs-streaming | Staffan Olsson | 2017-11-09 | 1 | -1/+1 |
| | | |||||
| * | Fixes manifest. I must have had a local edit last time. | Staffan Olsson | 2017-10-30 | 1 | -1/+1 |
| | | |||||
| * | Merge pull request #86 from Yolean/atamon-patch-1 | solsson | 2017-10-30 | 1 | -2/+2 |
| |\ | | | | | | | Fix retention from 0.8 days to 8 days | ||||
| | * | Fix retention from 0.8 days to 8 daysatamon-patch-1 | Anton Lindgren | 2017-10-30 | 1 | -2/+2 |
| |/ | | | | | | | | | Silly change, but 0.8 days is very short. Google helped me verify the math. | ||||
| * | Aligns RBAC with addons->folders for v3.0.0 | Staffan Olsson | 2017-10-27 | 1 | -0/+0 |
| | | |||||
| * | Fixes JSON syntax, topic is jq:able now | Staffan Olsson | 2017-10-27 | 1 | -2/+2 |
| | | |||||
| * | Needs to be tweaked depending on the churn | Staffan Olsson | 2017-10-27 | 1 | -1/+1 |
| | | |||||
| * | An actual assertion | Staffan Olsson | 2017-10-27 | 1 | -10/+72 |
| | | |||||
| * | Manifests updated to 1.8 and v3.0.0 pre-merge | Staffan Olsson | 2017-10-27 | 3 | -2/+10 |
| | | |||||
| * | kafkacat's debug output solves the silence, but ... | Staffan Olsson | 2017-10-26 | 1 | -2/+0 |
| | | | | | | | | | | | | to see the error message (like missing RBAC) you basically have to run the curl command. I'd like startup to be as fast as possible, to not miss events, so I hesitate to add checks. | ||||
| * | bash -e is important, in combination with curl -f, so ... | Staffan Olsson | 2017-10-26 | 1 | -12/+2 |
| | | | | | | | | | | we don't send error messages to the topic (even if it's json -- format is different and it's pretty printed) | ||||
| * | Argh, curl will pretty print the json ... | Staffan Olsson | 2017-10-26 | 1 | -1/+11 |
| | | | | | | | | and kafkacat will produce each line separately | ||||
| * | Makes things a bit less obscure if for example RBAC fails | Staffan Olsson | 2017-10-26 | 1 | -2/+12 |
| | | |||||
| * | Use an image with new kafkacat and curl versions | Staffan Olsson | 2017-10-26 | 1 | -1/+1 |
| | | |||||
| * | Not a proper test yet, but the PR documents how to use it to see events | Staffan Olsson | 2017-08-05 | 1 | -7/+2 |
| | | |||||
| * | Moves the example comsumer to the test namespace | Staffan Olsson | 2017-08-05 | 1 | -5/+4 |
| | | |||||
| * | Adds RBAC policy for curl, default service account | Staffan Olsson | 2017-08-05 | 1 | -0/+30 |
| | | |||||
| * | Latest build suppors snappy compression | Staffan Olsson | 2017-08-05 | 2 | -2/+2 |
| | | |||||
| * | Works with my current kafka image, and the test consumer still sees JSON | Staffan Olsson | 2017-08-05 | 1 | -1/+1 |
| | | |||||
| * | Testing compression but solsson/kafka:0.11.0.0 throws ... | Staffan Olsson | 2017-08-05 | 1 | -0/+1 |
| | | | | | | | | | | | | | | | | | | Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.xerial.snappy.Snappy at org.xerial.snappy.SnappyInputStream.readFully(SnappyInputStream.java:145) at org.xerial.snappy.SnappyInputStream.readHeader(SnappyInputStream.java:99) at org.xerial.snappy.SnappyInputStream.<init>(SnappyInputStream.java:59) at org.apache.kafka.common.record.CompressionType$3.wrapForInput(CompressionType.java:82) ... 40 more | ||||
| * | Produces proper json. Let's see when curl gives up and the container restarts. | Staffan Olsson | 2017-08-05 | 1 | -2/+1 |
| | | |||||
| * | Quite interesting way to test a command from yaml - see it in logs | Staffan Olsson | 2017-08-05 | 1 | -1/+3 |
| | | |||||
| * | wip | Staffan Olsson | 2017-08-05 | 1 | -5/+6 |
| | | |||||
| * | Produces and reads events | Staffan Olsson | 2017-08-05 | 3 | -2/+72 |
| | | |||||
| * | Creates a pod for expermentation with kubectl and kafkacat | Staffan Olsson | 2017-08-05 | 1 | -0/+27 |
| | | |||||
* | | Merge pull request #107 from Yolean/yolean-topic-management | solsson | 2017-12-18 | 3 | -56/+25 |
|\ \ | | | | | | | Embrace auto.topic.create; trust defaults for production topics | ||||
| * | | Deprecates our own statefulset pod label kafka-broker-idyolean-topic-management | Staffan Olsson | 2017-12-14 | 2 | -0/+3 |
| | | | |||||
| * | | I find it scary when broker start logs: | Staffan Olsson | 2017-12-14 | 1 | -0/+1 |
| | | | | | | | | | | | | | | | | | | | | | log.dir = /tmp/kafka-logs log.dirs = /var/lib/kafka/data/topics but this is the lesser of two evils compared to duplicate values | ||||
| * | | Merge branch 'topic-config-together' into yolean-topic-management | Staffan Olsson | 2017-12-13 | 2 | -60/+21 |
| |\ \ | |||||
| | * | | Now was a good time to get rid of the last --override | Staffan Olsson | 2017-12-13 | 2 | -3/+1 |
| | | | | | | | | | | | | | | | | as we now encourage close scrutiny of the config file. | ||||
| | * | | Moves the essential data path config to the | Staffan Olsson | 2017-12-13 | 2 | -3/+1 |
| | | | | | | | | | | | | | | | | config location suggested by Kafka's sample conf. | ||||
| | * | | Permanent retention is a friendlier default, | Staffan Olsson | 2017-12-13 | 2 | -3/+1 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | and easy to reconfigure per topic as they grow. We already had that, but this branch cares about grouping such conf. It also encourages topic defaults geared towards persistent data. | ||||
| | * | | Places the values that are most likely to need attention at the top | Staffan Olsson | 2017-12-13 | 1 | -52/+19 |
| |/ / | |||||
| * | | Gathers the config that has to do with topic creation | Staffan Olsson | 2017-12-13 | 2 | -2/+3 |
| | | | | | | | | | | | | | | | | | | | | | in one place. These values are critical to maintain for those, like us, who make use of auto create topics for production data. Also a step towards #72 and #77. | ||||
| * | | Enables auto create topics because there's use cases for adding | Staffan Olsson | 2017-12-13 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | | | topics at runtime, such as splitting a stream based on some business enum. Producers and Kafka Streams apps would otherwise need to set up an AdminClient to do that. This reverts commit: 0681cc515fa1c505b905ef60c7d3132e8d7510af | ||||
| * | | Lets clusters define their preferred (prod) replication factor | Staffan Olsson | 2017-12-01 | 1 | -0/+3 |
| | | | | | | | | | | | | | | | so that we can omit replication-factor when creating topics, as we benefit from reusing such commands or definitions across dev-qa-prod. | ||||
* | | | Merge pull request #104 from StevenACoffman/ADD_AWS | solsson | 2017-12-08 | 2 | -0/+20 |
|\ \ \ | |/ / |/| | | ADD_AWS: Add AWS storage classes | ||||
| * | | ADD_AWS: Add AWS storage class | Steve Coffman | 2017-12-08 | 2 | -0/+20 |
|/ / | |||||
* | | Removes some "platform" ideas from readme as they need real PRs | Staffan Olsson | 2017-12-01 | 1 | -2/+0 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | rather than a couple of sentences. In response to #103. Regarding Kafka Streams I no longer think we need examples, because any dockerized streams application can run as a deployment. An example of Kafka Connect would be useful, in particular the combination of a custom image (or one with stock connectors) and a Connect cluster manifest. This is tracked in #69, but not the relation to https://github.com/solsson/dockerfiles/tree/master/connect-* KSQL (#68) is highly interesting. | ||||
* | | Merge pull request #96 from Yolean/enable-broker-jmx | solsson | 2017-11-10 | 1 | -0/+4 |
|\ \ | | | | | | | Enable broker JMX_PORT 5555 | ||||
| * | | Exposes JMX for brokers, to typical monitoring setupsenable-broker-jmx | Staffan Olsson | 2017-11-09 | 1 | -0/+4 |
| | | | | | | | | | | | | | | | | | | | | | Already included in #49, but here we don't add any export container to the pod. Can be utilized by kafka-manager (#83) - just tick the JMX box when adding a cluster - to see bytes in/out rates. | ||||
* | | | Merge pull request #94 from Yolean/restore-ondelete-behaviorv3.0.1 | solsson | 2017-11-09 | 3 | -0/+6 |
|\ \ \ | |/ / |/| | | Disables RollingUpdate, i.e. reverts to pre-1.7 behavior | ||||
| * | | Sets OnDelete explicitly, as RollingUpdate is a new defaultrestore-ondelete-behavior | Staffan Olsson | 2017-11-09 | 3 | -0/+6 |
|/ / | | | | | | | | | | | | | | | Due to the use of config map for most of the conifg, RollingUpdate will be surprising, while still not preventing running pods that don't have the applied configuration. An automation effort would be required for proper RollingUpdate behavior. |