GH-1776: Fix transactional Template with Overrides
Resolves https://github.com/spring-projects/spring-kafka/issues/1776

Set `transactional` flag using overrides.

**cherry-pick to 2.6.x, 2.5.x**

GH-1776: Fix transactional Template with Overrides
Resolves https://github.com/spring-projects/spring-kafka/issues/1776

Set `transactional` flag using overrides.

**cherry-pick to 2.6.x, 2.5.x**

GH-1776: Fix transactional Template with Overrides
Resolves https://github.com/spring-projects/spring-kafka/issues/1776

Set `transactional` flag using overrides.

**cherry-pick to 2.6.x, 2.5.x**

Javadoc Polishing

GH-1774: kafka-clients 2.8.0 Compatibility
Resolves https://github.com/spring-projects/spring-kafka/issues/1774

- changes to `BrokerState`
- suppress some deprecation warnings

* Remove unnecessary static field.

* Remove unnecessary warning suppressions.

(S)FTP Doc Polishing

(S)FTP Doc Polishing

GH-1770: Fix ClientId for @KafkaListener
Resolves https://github.com/spring-projects/spring-kafka/issues/1770

The clientId property, if set on the container factory, is overwritten
by an empty String if not defined on the annotation.

Check for an empty String (groupId too).

**cherry-pick to 2.6.x**

* Use simpler JavaUtils method.

GH-1770: Fix ClientId for @KafkaListener
Resolves https://github.com/spring-projects/spring-kafka/issues/1770

The clientId property, if set on the container factory, is overwritten
by an empty String if not defined on the annotation.

Check for an empty String (groupId too).

**cherry-pick to 2.6.x**

* Use simpler JavaUtils method.

(S)FTP Doc Polishing

(S)FTP Doc Polishing

(S)FTP Doc Polishing

GH-3520: Improve TcpConnectionInterceptor Javadocs
Resolves https://github.com/spring-projects/spring-integration/issues/3520

GH-1315: Add onFailed() to ConnectionListener
Resolves https://github.com/spring-projects/spring-amqp/issues/1315

**cherry-pick to 2.2.x**

* Fix `@since` in the new test class

GH-3526: Fix Infinite Loop in FailoverCConnFactory
Resolves https://github.com/spring-projects/spring-integration/issues/3526

`FailoverClientConnectionFactory`

The logic to detect we had iterated over all factories and including
the one from which the previous connection was established was incorrect,
causing an infite loop until one of the factory connections was successful.

Change the logic to detect we have reset the iterator and the current failure
is from the same factory as the one from which the previous connection was
established.

**cherry-pick to 5.4.x, 5.3.x**

* Add diagnostics.

* Fix race in test.

* More race fixes and diagnostics.

* Remove diagnostics.

GH-3526: Fix Infinite Loop in FailoverCConnFactory
Resolves https://github.com/spring-projects/spring-integration/issues/3526

`FailoverClientConnectionFactory`

The logic to detect we had iterated over all factories and including
the one from which the previous connection was established was incorrect,
causing an infite loop until one of the factory connections was successful.

Change the logic to detect we have reset the iterator and the current failure
is from the same factory as the one from which the previous connection was
established.

**cherry-pick to 5.4.x, 5.3.x**

* Add diagnostics.

* Fix race in test.

* More race fixes and diagnostics.

* Remove diagnostics.

GH-3523: TcpConnectionEvent Fixes
Resolves https://github.com/spring-projects/spring-integration/issues/3523

- `TcpNetConnection` - publish open event on reader thread to avoid race with first read.
- Intercepted connections - Ensure that the event source is always the outermost interceptor.
- Also reduce delays during NIO client connect.

**cherry-pick to 5.4.x, 5.3.x**

5.3.x will require cherry picking GH-3509 commits.

Remove Invalid Reactive Test
- author misunderstood `sendOffsetsToTransaction`; the test sends the offsets
  for a produced record.

Don't Log Converted Message With Projection
`toString()` cannot be invoked on the payload proxy created by
the project factory.

GH-3509: Fix Memory Leak with Intercepted TCP Conn
Resolves https://github.com/spring-projects/spring-integration/issues/3509

When a connection was intercepted, the `TcpSender.add...` was called with the
interceptor, but the `removeDead...` was called with the actual connection,
causing a memory leak.

Always call the `TcpSender` with the outer-most interceptor.

# Conflicts:
#        spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetServerConnectionFactory.java
#        spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpSendingMessageHandlerTests.java

GH-3520: Improve TcpConnectionInterceptor Javadocs
Resolves https://github.com/spring-projects/spring-integration/issues/3520

GH-3526: Fix Infinite Loop in FailoverCConnFactory
Resolves https://github.com/spring-projects/spring-integration/issues/3526

`FailoverClientConnectionFactory`

The logic to detect we had iterated over all factories and including
the one from which the previous connection was established was incorrect,
causing an infite loop until one of the factory connections was successful.

Change the logic to detect we have reset the iterator and the current failure
is from the same factory as the one from which the previous connection was
established.

**cherry-pick to 5.4.x, 5.3.x**

* Add diagnostics.

* Fix race in test.

* More race fixes and diagnostics.

* Remove diagnostics.

GH-536: Fix test for backport

GH-536: Fix test for backport

Checkstyle Fixes

Diagnostics for Flaky Reactor Test

GH-3509: Fix if test in previous commit
Caused interceptor to be skipped.

**cherry-pick to 5.4.x**

* Fix race in new tests

* Remove overloaded conn id in test interceptor.

GH-3509: Fix Memory Leak with Intercepted TCP Conn
Resolves https://github.com/spring-projects/spring-integration/issues/3509

When a connection was intercepted, the `TcpSender.add...` was called with the
interceptor, but the `removeDead...` was called with the actual connection,
causing a memory leak.

Always call the `TcpSender` with the outer-most interceptor.

# Conflicts:
#        spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetServerConnectionFactory.java
#        spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpSendingMessageHandlerTests.java

GH-3509: Fix if test in previous commit
Caused interceptor to be skipped.

**cherry-pick to 5.4.x**

* Fix race in new tests

* Remove overloaded conn id in test interceptor.

GH-3509: Fix if test in previous commit
Caused interceptor to be skipped.

**cherry-pick to 5.4.x**

* Fix race in new tests

* Remove overloaded conn id in test interceptor.

GH-1736: Depr. StreamsBuilderFactoryBeanCustomizer
Resolves https://github.com/spring-projects/spring-kafka/issues/1736

**cherry-pick to 2.6.x**