组织ID: |
org.springframework.kafka |
项目ID: |
spring-kafka |
版本: |
2.2.7.RELEASE |
最后修改时间: |
2019-06-15 08:31:33 |
包类型: |
java-source (源码) |
大小: |
251.78KB |
|
Maven引入代码: |
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.2.7.RELEASE</version>
<classifier>sources</classifier>
<type>java-source</type>
</dependency>
|
Gradle引入代码: |
org.springframework.kafka:spring-kafka:2.2.7.RELEASE
|
下载Jar包: |
|
Jar包内容: |
META-INF/MANIFEST.MF
org/springframework/kafka/config/KafkaListenerEndpointRegistry.java
org/springframework/kafka/config/MethodKafkaListenerEndpoint.java
org/springframework/kafka/config/KafkaListenerEndpointRegistrar.java
org/springframework/kafka/config/KafkaListenerEndpointAdapter.java
org/springframework/kafka/config/MultiMethodKafkaListenerEndpoint.java
org/springframework/kafka/config/KafkaListenerContainerFactory.java
org/springframework/kafka/config/KafkaStreamsCustomizer.java
org/springframework/kafka/config/StreamsBuilderFactoryBean.java
org/springframework/kafka/config/KafkaListenerConfigUtils.java
org/springframework/kafka/config/KafkaStreamsConfiguration.java
org/springframework/kafka/config/CompositeKafkaStreamsCustomizer.java
org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java
org/springframework/kafka/config/package-info.java
org/springframework/kafka/config/KafkaListenerEndpoint.java
org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java
org/springframework/kafka/config/ConcurrentKafkaListenerContainerFactory.java
org/springframework/kafka/KafkaException.java
org/springframework/kafka/listener/RemainingRecordsErrorHandler.java
org/springframework/kafka/listener/ContainerStoppingBatchErrorHandler.java
org/springframework/kafka/listener/ContainerAwareErrorHandler.java
org/springframework/kafka/listener/ConsumerAwareBatchErrorHandler.java
org/springframework/kafka/listener/BatchAcknowledgingConsumerAwareMessageListener.java
org/springframework/kafka/listener/MessageListenerContainer.java
org/springframework/kafka/listener/GenericMessageListenerContainer.java
org/springframework/kafka/listener/KafkaListenerErrorHandler.java
org/springframework/kafka/listener/adapter/FilteringMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/DelegatingInvocableHandler.java
org/springframework/kafka/listener/adapter/AbstractDelegatingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/AbstractFilteringMessageListener.java
org/springframework/kafka/listener/adapter/RetryingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/InvocationResult.java
org/springframework/kafka/listener/adapter/BatchMessagingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/HandlerAdapter.java
org/springframework/kafka/listener/adapter/package-info.java
org/springframework/kafka/listener/adapter/AbstractRetryingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/ReplyHeadersConfigurer.java
org/springframework/kafka/listener/adapter/RecordFilterStrategy.java
org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
org/springframework/kafka/listener/adapter/FilteringBatchMessageListenerAdapter.java
org/springframework/kafka/listener/ConsumerSeekAware.java
org/springframework/kafka/listener/KafkaMessageListenerContainer.java
org/springframework/kafka/listener/RecordInterceptor.java
org/springframework/kafka/listener/DefaultAfterRollbackProcessor.java
org/springframework/kafka/listener/MessageListener.java
org/springframework/kafka/listener/ErrorHandler.java
org/springframework/kafka/listener/ListenerUtils.java
org/springframework/kafka/listener/ConsumerAwareErrorHandler.java
org/springframework/kafka/listener/AcknowledgingConsumerAwareMessageListener.java
org/springframework/kafka/listener/SeekToCurrentErrorHandler.java
org/springframework/kafka/listener/BatchErrorHandler.java
org/springframework/kafka/listener/AbstractMessageListenerContainer.java
org/springframework/kafka/listener/ContainerAwareBatchErrorHandler.java
org/springframework/kafka/listener/ListenerType.java
org/springframework/kafka/listener/ConsumerAwareMessageListener.java
org/springframework/kafka/listener/LoggingErrorHandler.java
org/springframework/kafka/listener/AcknowledgingMessageListener.java
org/springframework/kafka/listener/ContainerStoppingErrorHandler.java
org/springframework/kafka/listener/GenericMessageListener.java
org/springframework/kafka/listener/BatchMessageListener.java
org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
org/springframework/kafka/listener/FailedRecordTracker.java
org/springframework/kafka/listener/ConsumerAwareListenerErrorHandler.java
org/springframework/kafka/listener/BatchAcknowledgingMessageListener.java
org/springframework/kafka/listener/DelegatingMessageListener.java
org/springframework/kafka/listener/package-info.java
org/springframework/kafka/listener/ConsumerAwareRebalanceListener.java
org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java
org/springframework/kafka/listener/BatchConsumerAwareMessageListener.java
org/springframework/kafka/listener/SeekToCurrentBatchErrorHandler.java
org/springframework/kafka/listener/AfterRollbackProcessor.java
org/springframework/kafka/listener/ContainerProperties.java
org/springframework/kafka/listener/LoggingCommitCallback.java
org/springframework/kafka/listener/BatchLoggingErrorHandler.java
org/springframework/kafka/listener/ListenerExecutionFailedException.java
org/springframework/kafka/listener/GenericErrorHandler.java
org/springframework/kafka/support/KafkaHeaders.java
org/springframework/kafka/support/CompositeProducerListener.java
org/springframework/kafka/support/DefaultKafkaHeaderMapper.java
org/springframework/kafka/support/ProducerListenerAdapter.java
org/springframework/kafka/support/SimpleKafkaHeaderMapper.java
org/springframework/kafka/support/SeekUtils.java
org/springframework/kafka/support/KafkaUtils.java
org/springframework/kafka/support/JacksonPresent.java
org/springframework/kafka/support/SendResult.java
org/springframework/kafka/support/KafkaStreamBrancher.java
org/springframework/kafka/support/LoggingProducerListener.java
org/springframework/kafka/support/TransactionSupport.java
org/springframework/kafka/support/LogIfLevelEnabled.java
org/springframework/kafka/support/Acknowledgment.java
org/springframework/kafka/support/TopicPartitionInitialOffset.java
org/springframework/kafka/support/KafkaNull.java
org/springframework/kafka/support/package-info.java
org/springframework/kafka/support/AbstractKafkaHeaderMapper.java
org/springframework/kafka/support/serializer/JsonSerializer.java
org/springframework/kafka/support/serializer/DeserializationException.java
org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java
org/springframework/kafka/support/serializer/JsonDeserializer.java
org/springframework/kafka/support/serializer/ErrorHandlingDeserializer.java
org/springframework/kafka/support/serializer/JsonSerde.java
org/springframework/kafka/support/KafkaHeaderMapper.java
org/springframework/kafka/support/ProducerListener.java
org/springframework/kafka/support/converter/BatchMessagingMessageConverter.java
org/springframework/kafka/support/converter/ProjectingMessageConverter.java
org/springframework/kafka/support/converter/BatchMessageConverter.java
org/springframework/kafka/support/converter/MessageConverter.java
org/springframework/kafka/support/converter/BytesJsonMessageConverter.java
org/springframework/kafka/support/converter/StringJsonMessageConverter.java
org/springframework/kafka/support/converter/DefaultJackson2JavaTypeMapper.java
org/springframework/kafka/support/converter/ConversionException.java
org/springframework/kafka/support/converter/MessagingMessageConverter.java
org/springframework/kafka/support/converter/KafkaMessageHeaders.java
org/springframework/kafka/support/converter/package-info.java
org/springframework/kafka/support/converter/RecordMessageConverter.java
org/springframework/kafka/support/converter/ClassMapper.java
org/springframework/kafka/support/converter/Jackson2JavaTypeMapper.java
org/springframework/kafka/support/converter/AbstractJavaTypeMapper.java
org/springframework/kafka/core/KafkaTemplate.java
org/springframework/kafka/core/KafkaOperations.java
org/springframework/kafka/core/KafkaProducerException.java
org/springframework/kafka/core/KafkaResourceHolder.java
org/springframework/kafka/core/CleanupConfig.java
org/springframework/kafka/core/ProducerFactoryUtils.java
org/springframework/kafka/core/DefaultKafkaConsumerFactory.java
org/springframework/kafka/core/ProducerFactory.java
org/springframework/kafka/core/DefaultKafkaProducerFactory.java
org/springframework/kafka/core/KafkaAdmin.java
org/springframework/kafka/core/package-info.java
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|
依赖Jar: |
无
|