ripping out ignore files
This commit is contained in:
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
File diff suppressed because one or more lines are too long
@@ -1 +0,0 @@
|
||||
com.example.kafkaapp.KafkaApp
|
||||
@@ -1,20 +0,0 @@
|
||||
spring:
|
||||
kafka:
|
||||
bootstrap-servers: localhost:9093
|
||||
consumer:
|
||||
group-id: kafka-spring-app-group
|
||||
security:
|
||||
protocol: SSL
|
||||
ssl:
|
||||
trust-store-location: file:/workspaces/java-2/kafka.pfx
|
||||
trust-store-password:
|
||||
trust-store-type: pkcs12
|
||||
key-store-location: file:/workspaces/java-2/kafka.pfx
|
||||
key-store-password:
|
||||
key-store-type: pkcs12
|
||||
key-password:
|
||||
properties:
|
||||
"ssl-endpoint-identification-algorithm": ""
|
||||
producer:
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer
|
||||
value-serializer: org.apache.kafka.common.serialization.StringSerializer
|
||||
@@ -1,12 +0,0 @@
|
||||
Manifest-Version: 1.0
|
||||
Main-Class: org.springframework.boot.loader.JarLauncher
|
||||
Start-Class: com.example.kafkaapp.KafkaApp
|
||||
Spring-Boot-Version: 3.0.4
|
||||
Spring-Boot-Classes: BOOT-INF/classes/
|
||||
Spring-Boot-Lib: BOOT-INF/lib/
|
||||
Spring-Boot-Classpath-Index: BOOT-INF/classpath.idx
|
||||
Spring-Boot-Layers-Index: BOOT-INF/layers.idx
|
||||
Build-Jdk-Spec: 21
|
||||
Implementation-Title: java-2
|
||||
Implementation-Version: 0.0.1-SNAPSHOT
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -1,2 +0,0 @@
|
||||
Manifest-Version: 1.0
|
||||
|
||||
@@ -14,7 +14,7 @@ services:
|
||||
image: confluentinc/cp-kafka:7.9.0
|
||||
container_name: kafka
|
||||
volumes:
|
||||
- /workspaces/java-2/creds:/etc/kafka/secrets/
|
||||
- /workspaces/bad-java/creds:/etc/kafka/secrets/
|
||||
depends_on:
|
||||
- zookeeper
|
||||
environment:
|
||||
|
||||
@@ -27,33 +27,3 @@ public class ProducerService {
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Configuration
|
||||
class KafkaProducerConfig {
|
||||
|
||||
@Bean
|
||||
public ProducerFactory<String, String> producerFactory() {
|
||||
Map<String, Object> props = new HashMap<>();
|
||||
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9093");
|
||||
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
|
||||
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
|
||||
props.put("security.protocol", "SSL");
|
||||
props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, "/workspaces/java-2/kafka.pfx");
|
||||
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, "");
|
||||
props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/workspaces/java-2/kafka.pfx");
|
||||
props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, "");
|
||||
props.put(SslConfigs.SSL_KEYSTORE_TYPE_CONFIG, "PKCS12");
|
||||
props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, "");
|
||||
|
||||
// ✅ Disable hostname verification (the "single extra property")
|
||||
props.put(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "");
|
||||
props.put("ssl.endpoint.identification.algorithm", "");
|
||||
|
||||
return new DefaultKafkaProducerFactory<>(props);
|
||||
}
|
||||
|
||||
@Bean
|
||||
public KafkaTemplate<String, String> kafkaTemplate() {
|
||||
return new KafkaTemplate<>(producerFactory());
|
||||
}
|
||||
}
|
||||
@@ -6,10 +6,10 @@ spring:
|
||||
security:
|
||||
protocol: SSL
|
||||
ssl:
|
||||
trust-store-location: file:/workspaces/java-2/kafka.pfx
|
||||
trust-store-location: file:/workspaces/bad-java/creds/kafka.pfx
|
||||
trust-store-password:
|
||||
trust-store-type: pkcs12
|
||||
key-store-location: file:/workspaces/java-2/kafka.pfx
|
||||
key-store-location: file:/workspaces/bad-java/creds/kafka.pfx
|
||||
key-store-password:
|
||||
key-store-type: pkcs12
|
||||
key-password:
|
||||
|
||||
Reference in New Issue
Block a user