This is an automated email from the ASF dual-hosted git repository. markap14 pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 783633c NIFI-8021: Fixed bug in ConsumeKafka_2_6 and ConsumeKafkaRecord_2_6 where explicit partition assignment causes issues with more than 1 concurrent task. Also fixed bug that prevented more nifi nodes than partitions because it didn't properly handle empty string for the list of partitions add 817f621 NIFI-8096 Deprecated ClientAuth references in SSLContextService No new revisions were added by this update. Summary of changes: .../http/TestHttpNotificationServiceSSL.java | 3 +- .../nifi/security/util/SslContextFactory.java | 61 +++++----------------- .../security/util/SslContextFactoryTest.groovy | 32 +++--------- .../nifi/io/socket/ServerSocketConfiguration.java | 4 +- .../apache/nifi/io/socket/SocketConfiguration.java | 4 +- .../amqp/processors/AbstractAMQPProcessor.java | 2 +- .../nifi/processors/aws/AbstractAWSProcessor.java | 3 +- .../apache/nifi/processors/beats/ListenBeats.java | 2 +- .../cassandra/AbstractCassandraProcessor.java | 16 +----- .../cassandra/AbstractCassandraProcessorTest.java | 17 ------ .../nifi/service/CassandraSessionProvider.java | 20 ++----- .../schemaregistry/ConfluentSchemaRegistry.java | 5 +- .../ElasticSearchClientServiceImpl.java | 3 +- .../apache/nifi/processors/email/ListenSMTP.java | 10 ++-- .../server/ConnectionLoadBalanceServerTest.groovy | 3 +- .../queue/clustered/LoadBalancedQueueIT.java | 3 +- .../remote/SocketRemoteSiteListenerTest.groovy | 11 +--- .../stateless/config/SslConfigurationUtil.java | 3 +- .../nifi/jms/cf/JMSConnectionFactoryHandler.java | 3 +- .../java/org/apache/nifi/ldap/LdapProvider.java | 5 +- .../nifi/ldap/tenants/LdapUserGroupProvider.java | 5 +- .../processors/lumberjack/ListenLumberjack.java | 3 +- .../processors/mongodb/AbstractMongoProcessor.java | 14 +---- .../mongodb/AbstractMongoProcessorTest.java | 26 +-------- .../nifi/mongodb/MongoDBControllerService.java | 20 ++----- .../apache/nifi/reporting/s2s/SiteToSiteUtils.java | 3 +- .../org/apache/nifi/processors/solr/SolrUtils.java | 7 +-- .../processors/solr/MockSSLContextService.java | 5 ++ .../controller/livy/LivySessionController.java | 3 +- .../apache/nifi/processors/splunk/PutSplunk.java | 3 +- .../apache/nifi/processors/standard/GetHTTP.java | 4 +- .../nifi/processors/standard/ListenHTTP.java | 11 +++- .../nifi/processors/standard/ListenRELP.java | 3 +- .../nifi/processors/standard/ListenSyslog.java | 2 +- .../apache/nifi/processors/standard/ListenTCP.java | 2 +- .../nifi/processors/standard/ListenTCPRecord.java | 2 +- .../apache/nifi/processors/standard/PutSyslog.java | 3 +- .../apache/nifi/processors/standard/PutTCP.java | 3 +- .../processors/standard/TestGetHTTPGroovy.groovy | 2 +- .../processors/standard/TestPostHTTPGroovy.groovy | 2 +- .../standard/ITestHandleHttpRequest.java | 7 ++- .../nifi/processors/standard/TestListenRELP.java | 3 +- .../nifi/processors/standard/TestListenTCP.java | 2 +- .../processors/standard/util/TCPTestServer.java | 3 +- .../client/DistributedMapCacheClientService.java | 3 +- .../client/DistributedSetCacheClientService.java | 3 +- .../cache/server/DistributedSetCacheServer.java | 3 +- .../server/map/DistributedMapCacheServer.java | 3 +- .../nifi/oauth2/OAuth2TokenProviderImpl.java | 3 +- .../apache/nifi/ssl/StandardSSLContextService.java | 50 ++++++++++++------ .../nifi/ssl/StandardSSLContextServiceTest.groovy | 4 +- .../org/apache/nifi/ssl/SSLContextServiceTest.java | 11 ++-- .../org/apache/nifi/ssl/SSLContextService.java | 24 ++++++--- 53 files changed, 147 insertions(+), 305 deletions(-)