diff options
Diffstat (limited to 'src/main/resources/common.properties')
| -rw-r--r-- | src/main/resources/common.properties | 46 |
1 files changed, 11 insertions, 35 deletions
diff --git a/src/main/resources/common.properties b/src/main/resources/common.properties index 4a28a54..ca8057f 100644 --- a/src/main/resources/common.properties +++ b/src/main/resources/common.properties @@ -1,37 +1,37 @@ #--------------------------------Kafka��������Ϣ------------------------------# #kafka�ĵ�ַ��Ϣ -kafka.consumer.broker=192.168.44.11:9092 +kafka.consumer.broker=192.168.54.241:9092 #kafka ��������topic -kafka.consumer.topic=SESSION-RECORD-COMPLETED +kafka.consumer.topic=SESSION-RECORD #���������� -kafka.consumer.group.id=topn-metrics-job-20231101-t1 +kafka.consumer.group.id=topn-metrics-job-20231101-t1-t #--------------------------------Kafka��������Ϣ------------------------------# #kafka�ĵ�ַ��Ϣ -kafka_producer_broker=192.168.44.12:9092 +kafka.producer.broker=192.168.44.12:9094 kafka.producer.topic=TRAFFIC-TOP-METRIC #--------------------------------topology����------------------------------# #�������� -job.name=TOPN-METRICS-JOB +job.name=agg_session_record_topn #source���ж� -kafka.consumer.parallelism=1 +kafka.consumer.parallelism=3 #�����ж� -task.parallelism=1 +task.parallelism=3 #���������ж� -orderby.parallelism=1 +orderby.parallelism=3 #��Ⲣ�жȣ�ͨ������orderby.parallelism -sink.parallelism=1 +sink.parallelism=3 #�����ӳٵȴ�ʱ�䵥λ�� -watermark.time=60 +watermark.time=90 #top������� top.limit=10000 @@ -41,13 +41,7 @@ window.time.minute=5 #--------------------------------Kafka��������------------------------------# #kafka source poll -kafka.consumer.max.poll.records=3000 -#kafka source connection timeout -kafka.consumer.session.timeout.ms=60000 - -#kafka source poll bytes -kafka.consumer.max.partition.fetch.bytes=31457280 #kafka�������Ƿ�����ȫ��֤ 0������ 1SSL 2 SASL kafka.consumer.security=0 @@ -62,7 +56,7 @@ kafka.consumer.pin=galaxy2019 tools.consumer.library=/home/bigdata/topology/dat/ #kafka�������Ƿ�����ȫ��֤ 0������ 1SSL 2 SASL -kafka.producer.security=0 +kafka.producer.security=2 #kafka SASL��֤�û��� kafka.producer.user=admin @@ -73,23 +67,5 @@ kafka.producer.pin=galaxy2019 #1SSL��Ҫ tools.producer.library=/home/bigdata/topology/dat/ -#producer���ԵĴ������� -kafka.producer.retries=1 - -#���ĺ������˵һ��Batch������֮��������ã��������Batch��û��д���������뷢�ͳ�ȥ�� -kafka.producer.linger.ms=1 - -#����ڳ�ʱ֮ǰδ�յ���Ӧ���ͻ��˽��ڱ�Ҫʱ���·������� -kafka.producer.request.timeout.ms=30000 - -#producer���ǰ���batch���з��͵�,���δ�С��Ĭ��:16384 -kafka.producer.batch.size=262144 - -#Producer�����ڻ�����Ϣ�Ļ�������С -kafka.producer.buffer.memory=134217728 -#�������������ÿ�η���Kafka���������������С,Ĭ��1048576 -kafka.producer.max.request.size=10485760 -#����kafkaѹ�����ͣ�Ĭ�ϲ����� -kafka.producer.compression.type=none |