Add all agent config to agent.conf file for convenient containerization use cases#7470
Conversation
Codecov Report
@@ Coverage Diff @@
## master #7470 +/- ##
============================================
- Coverage 58.81% 56.68% -2.13%
+ Complexity 4390 4363 -27
============================================
Files 1035 1075 +40
Lines 26592 27346 +754
Branches 2627 2711 +84
============================================
- Hits 15640 15502 -138
- Misses 9571 10482 +911
+ Partials 1381 1362 -19
Continue to review full report at Codecov.
|
bc6de0f to
0abea49
Compare
0abea49 to
6d4de99
Compare
wu-sheng
left a comment
There was a problem hiding this comment.
Once all tests passed, I am good with this.
90acd98 to
038199b
Compare
mrproliu
left a comment
There was a problem hiding this comment.
I see some default value is not right with the document, I think we should update too.
| # Timeout period of reading topics from the Kafka server, the unit is second. | ||
| plugin.kafka.get_topic_timeout=${SW_GET_TOPIC_TIMEOUT:10} | ||
| # Kafka producer configuration. | ||
| plugin.kafka.consumer_config=${SW_PLUGIN_KAFKA_CONSUMER_CONFIG:} |
There was a problem hiding this comment.
Can't see where is using this config item?
There was a problem hiding this comment.
I think it is in KafkaProducerManager#run.
@dmsolr Could you be clear about how to add this property? I mean for a hashmap type.
There was a problem hiding this comment.
It is my mistake. The proper configuration item is plugin.kafka.producer_config.
The format is
plugin.kafka.producer_config[key]=value
and the key list was here.
I do not try to set it in JVM Options. It seems that you can't do it.
There was a problem hiding this comment.
@kezhenxu94 Any preference to do this? This mode is hard to override through system env. We can't list them all, they are too many.
There was a problem hiding this comment.
@kezhenxu94 Any preference to do this? This mode is hard to override through system env. We can't list them all, they are too many.
What about avoiding the key in the config key, for example plugin.kafka.producer_config=key1=value1,key2=value2, if we could use JSON in agent, we may use plugin.kafka.producer_config={"key":"val"}?
There was a problem hiding this comment.
plugin.kafka.producer_config=key1=value1,key2=value2
I prefer to support this first in the agent initialization through another PR? @dmsolr Could you do this?
There was a problem hiding this comment.
plugin.kafka.producer_config=key1=value1,key2=value2
It is good to me.
@dmsolr Could you do this?
Sure.
There was a problem hiding this comment.
Please create an issue to track this.
038199b to
738f6b8
Compare
|
I rerun the Kafka e2e. The Kafka/Meter is always unstable :( |
|
@kezhenxu94 Could you check meter e2e? It seems failing again. |
738f6b8 to
05d6385
Compare
|
I find some configurations are in configurations.md , but not in the agent.config , such as |
If there are names mismatch or missing, submit a pull request to fix directly. |
@dashanji can you open a pull request to fix this? For |
OK. |
OK , I will open a pull request to fix it. |
|
|
Sorry I don't know much about java, so I can't realize this feature at present. |
OK, then if we need someone to add this feature first, otherwise, But others you proposed, feel free to send a pull request to fix. |
CHANGESlog.