aboutsummaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Removes outdated comment; these tests can't grow more complexevents-kube-error-reportingStaffan Olsson2018-02-031-6/+0
|
* Creates the test, but for manual scale upStaffan Olsson2018-01-091-1/+3
| | | | ... when you think there'll be a sufficient event rate
* Revert "Workaround" as it makes the test quite unusefulStaffan Olsson2018-01-091-2/+2
| | | | This reverts commit abe3491e0c29d44b89eeedff5c709ea79c0351d4.
* Less silent: kubectl -n kafka logs -l app=events | grep curlStaffan Olsson2018-01-091-0/+1
|
* Workaround for the test issue in #109, maybeStaffan Olsson2018-01-081-2/+2
|
* Merge pull request #117 from Yolean/broker-init-pod-lablersolsson2018-01-083-7/+49
|\ | | | | Fix RBAC, set useful labels on broker pods from init script
| * Sets all labels at the end of the init script,broker-init-pod-lablerStaffan Olsson2018-01-082-6/+8
| | | | | | | | | | | | to speed up a bit and reduce the risk that it interferes with actual config. Also if the init script goes crash looping you won't get warnings about labels already being set.
| * Sets other useful labels, for #78 and #56Staffan Olsson2018-01-082-7/+9
| |
| * Revert "Deprecates our own statefulset pod label kafka-broker-id"Staffan Olsson2018-01-082-3/+0
| | | | | | | | This reverts commit 096e3bdfba31d2918520011886a6a0d1f1b08c84.
| * Adds the required RBAC for the init script to set the kafka-broker-id labelStaffan Olsson2018-01-081-0/+41
|/
* Merge pull request #115 from StevenACoffman/cleanupsolsson2018-01-084-7/+5
|\ | | | | Minor cleanups
| * cleanup: Minor cleanupsSteve Coffman2018-01-054-7/+5
|/
* Merge pull request #92 from Yolean/1.8-kube-eventssolsson2017-12-183-0/+170
|\ | | | | Stream kube events to topic, as opt-in folder instead of addon
| * Modernize based on1.8-kube-eventsStaffan Olsson2017-12-183-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-streamingStaffan Olsson2017-11-091-1/+1
| |
| * Fixes manifest. I must have had a local edit last time.Staffan Olsson2017-10-301-1/+1
| |
| * Merge pull request #86 from Yolean/atamon-patch-1solsson2017-10-301-2/+2
| |\ | | | | | | Fix retention from 0.8 days to 8 days
| | * Fix retention from 0.8 days to 8 daysatamon-patch-1Anton Lindgren2017-10-301-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.0Staffan Olsson2017-10-271-0/+0
| |
| * Fixes JSON syntax, topic is jq:able nowStaffan Olsson2017-10-271-2/+2
| |
| * Needs to be tweaked depending on the churnStaffan Olsson2017-10-271-1/+1
| |
| * An actual assertionStaffan Olsson2017-10-271-10/+72
| |
| * Manifests updated to 1.8 and v3.0.0 pre-mergeStaffan Olsson2017-10-273-2/+10
| |
| * kafkacat's debug output solves the silence, but ...Staffan Olsson2017-10-261-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 Olsson2017-10-261-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 Olsson2017-10-261-1/+11
| | | | | | | | and kafkacat will produce each line separately
| * Makes things a bit less obscure if for example RBAC failsStaffan Olsson2017-10-261-2/+12
| |
| * Use an image with new kafkacat and curl versionsStaffan Olsson2017-10-261-1/+1
| |
| * Not a proper test yet, but the PR documents how to use it to see eventsStaffan Olsson2017-08-051-7/+2
| |
| * Moves the example comsumer to the test namespaceStaffan Olsson2017-08-051-5/+4
| |
| * Adds RBAC policy for curl, default service accountStaffan Olsson2017-08-051-0/+30
| |
| * Latest build suppors snappy compressionStaffan Olsson2017-08-052-2/+2
| |
| * Works with my current kafka image, and the test consumer still sees JSONStaffan Olsson2017-08-051-1/+1
| |
| * Testing compression but solsson/kafka:0.11.0.0 throws ...Staffan Olsson2017-08-051-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 Olsson2017-08-051-2/+1
| |
| * Quite interesting way to test a command from yaml - see it in logsStaffan Olsson2017-08-051-1/+3
| |
| * wipStaffan Olsson2017-08-051-5/+6
| |
| * Produces and reads eventsStaffan Olsson2017-08-053-2/+72
| |
| * Creates a pod for expermentation with kubectl and kafkacatStaffan Olsson2017-08-051-0/+27
| |
* | Merge pull request #107 from Yolean/yolean-topic-managementsolsson2017-12-183-56/+25
|\ \ | | | | | | Embrace auto.topic.create; trust defaults for production topics
| * | Deprecates our own statefulset pod label kafka-broker-idyolean-topic-managementStaffan Olsson2017-12-142-0/+3
| | |
| * | I find it scary when broker start logs:Staffan Olsson2017-12-141-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-managementStaffan Olsson2017-12-132-60/+21
| |\ \
| | * | Now was a good time to get rid of the last --overrideStaffan Olsson2017-12-132-3/+1
| | | | | | | | | | | | | | | | as we now encourage close scrutiny of the config file.
| | * | Moves the essential data path config to theStaffan Olsson2017-12-132-3/+1
| | | | | | | | | | | | | | | | config location suggested by Kafka's sample conf.
| | * | Permanent retention is a friendlier default,Staffan Olsson2017-12-132-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 topStaffan Olsson2017-12-131-52/+19
| |/ /
| * | Gathers the config that has to do with topic creationStaffan Olsson2017-12-132-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 addingStaffan Olsson2017-12-131-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 factorStaffan Olsson2017-12-011-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.